org.apache.hadoop.mapred
Interface MapRunnable

All Superinterfaces:

JobConfigurable

All Known Implementing Classes:

MapRunner, MultithreadedMapRunner

public interface MapRunnable
extends JobConfigurable

Expert: Permits greater control of map processing. For example, implementations might perform multi-threaded, asynchronous mappings.

Method Summary

void	run(RecordReader input, OutputCollector output, Reporter reporter) Called to execute mapping.

Methods inherited from interface org.apache.hadoop.mapred.JobConfigurable

configure

Method Detail

run

void run(RecordReader input,
         OutputCollector output,
         Reporter reporter)
         throws IOException

Called to execute mapping. Mapping is complete when this returns.

Parameters:

input - the RecordReader with input key/value pairs.

output - the OutputCollector for mapped key/value pairs.

Throws:

IOException