KEYIN
- the input key type for the taskVALUEIN
- the input value type for the taskKEYOUT
- the output key type for the taskVALUEOUT
- the output value type for the taskpublic interface TaskInputOutputContext<KEYIN,VALUEIN,KEYOUT,VALUEOUT> extends TaskAttemptContext
CACHE_ARCHIVES_VISIBILITIES, CACHE_FILE_VISIBILITIES, COMBINE_CLASS_ATTR, INPUT_FORMAT_CLASS_ATTR, JAR_UNPACK_PATTERN, JOB_ACL_MODIFY_JOB, JOB_ACL_VIEW_JOB, JOB_CANCEL_DELEGATION_TOKEN, JOB_NAMENODES, MAP_CLASS_ATTR, MAP_MEMORY_PHYSICAL_MB, MAP_OUTPUT_COLLECTOR_CLASS_ATTR, MAPREDUCE_TASK_CLASSPATH_PRECEDENCE, OUTPUT_FORMAT_CLASS_ATTR, PARTITIONER_CLASS_ATTR, REDUCE_CLASS_ATTR, REDUCE_MEMORY_PHYSICAL_MB, SHUFFLE_CONSUMER_PLUGIN_ATTR, USER_LOG_RETAIN_HOURS
Modifier and Type | Method and Description |
---|---|
KEYIN |
getCurrentKey()
Get the current key.
|
VALUEIN |
getCurrentValue()
Get the current value.
|
OutputCommitter |
getOutputCommitter()
Get the
OutputCommitter for the task-attempt. |
boolean |
nextKeyValue()
Advance to the next key, value pair, returning null if at end.
|
void |
write(KEYOUT key,
VALUEOUT value)
Generate an output key/value pair.
|
getCounter, getCounter, getStatus, getTaskAttemptID, setStatus
getArchiveClassPaths, getArchiveTimestamps, getCacheArchives, getCacheFiles, getCombinerClass, getCombinerKeyGroupingComparator, getConfiguration, getCredentials, getFileClassPaths, getFileTimestamps, getGroupingComparator, getInputFormatClass, getJar, getJobID, getJobName, getJobSetupCleanupNeeded, getLocalCacheArchives, getLocalCacheFiles, getMapOutputKeyClass, getMapOutputValueClass, getMapperClass, getMaxMapAttempts, getMaxReduceAttempts, getNumReduceTasks, getOutputFormatClass, getOutputKeyClass, getOutputValueClass, getPartitionerClass, getProfileEnabled, getProfileParams, getReducerClass, getSortComparator, getSymlink, getUser, getWorkingDirectory, userClassesTakesPrecedence
boolean nextKeyValue() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
KEYIN getCurrentKey() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
VALUEIN getCurrentValue() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
void write(KEYOUT key, VALUEOUT value) throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
OutputCommitter getOutputCommitter()
OutputCommitter
for the task-attempt.OutputCommitter
for the task-attemptCopyright © 2009 The Apache Software Foundation