org.apache.hadoop.mapred.lib
Class MultithreadedMapRunner

java.lang.Object
  org.apache.hadoop.mapred.lib.MultithreadedMapRunner

All Implemented Interfaces:

JobConfigurable, MapRunnable

public class MultithreadedMapRunner
extends Object
implements MapRunnable

Multithreaded implementation for @link org.apache.hadoop.mapred.MapRunnable.

It can be used instead of the default implementation,

Author:

Alejandro Abdelnur

Constructor Summary

MultithreadedMapRunner()

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

MultithreadedMapRunner

public MultithreadedMapRunner()

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