com.bigdata.service.mapred
Class AbstractFileInputMapTask

java.lang.Object
  com.bigdata.service.mapred.AbstractMapTask
      com.bigdata.service.mapred.AbstractFileInputMapTask

All Implemented Interfaces:

IMapTask, ITask, Serializable

Direct Known Subclasses:

ExtractKeywords, NOPMapTask, ReadOnlyMapTask

public abstract class AbstractFileInputMapTask
extends AbstractMapTask

Abstract base class for IMapTasks accepting a filename as the "key" and the file contents as the "value".

Version:

$Id: AbstractFileInputMapTask.java 2265 2009-10-26 12:51:06Z thompsonbry $

Author:

Bryan Thompson

See Also:

Serialized Form

Field Summary

Fields inherited from class com.bigdata.service.mapred.AbstractMapTask

hashFunction, nreduce, source, uuid

Fields inherited from interface com.bigdata.service.mapred.IMapTask

log

Constructor Summary

protected

AbstractFileInputMapTask(UUID uuid, Object source, int nreduce, IHashFunction hashFunction)

Method Summary

void	input(File file) Used to read from the AbstractMapTask.getSource() when it is a File.
protected abstract void	input(File input, InputStream is)

Methods inherited from class com.bigdata.service.mapred.AbstractMapTask

getDataOutputBuffer, getHistogram, getKeyBuilder, getSource, getTupleCount, getTuples, getUUID, output, output

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AbstractFileInputMapTask

protected AbstractFileInputMapTask(UUID uuid,
                                   Object source,
                                   int nreduce,
                                   IHashFunction hashFunction)

Method Detail

input

public final void input(File file)
                 throws Exception

Used to read from the AbstractMapTask.getSource() when it is a File.

Parameters:

file - The data source.

Throws:

Exception

input

protected abstract void input(File input,
                              InputStream is)
                       throws Exception

Throws:

Exception