org.apache.hadoop.mapred
Class MapRunner

java.lang.Object
  org.apache.hadoop.mapred.MapRunner

All Implemented Interfaces:

JobConfigurable, MapRunnable

public class MapRunner
extends Object
implements MapRunnable

Default MapRunnable implementation.

Constructor Summary

MapRunner()

Method Summary

void	configure(JobConf job) Initializes a new instance from a JobConf.
void	run(RecordReader input, OutputCollector output, Reporter reporter) Called to execute mapping.

Methods inherited from class java.lang.Object

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

Constructor Detail

MapRunner

public MapRunner()

Method Detail

configure

public void configure(JobConf job)

Description copied from interface: JobConfigurable

Initializes a new instance from a JobConf.

Specified by:

configure in interface JobConfigurable

Parameters:

job - the configuration

run

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

Description copied from interface: MapRunnable

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

Specified by:

run in interface MapRunnable

Parameters:

input - the RecordReader with input key/value pairs.

output - the OutputCollector for mapped key/value pairs.

Throws:

IOException