org.apache.hadoop.mapred.lib
Class MultithreadedMapRunner<K1,V1,K2,V2>

java.lang.Object
  extended by org.apache.hadoop.mapred.lib.MultithreadedMapRunner<K1,V1,K2,V2>
All Implemented Interfaces:
JobConfigurable, MapRunnable<K1,V1,K2,V2>

@InterfaceAudience.Public
@InterfaceStability.Stable
public class MultithreadedMapRunner<K1,V1,K2,V2>
extends Object
implements MapRunnable<K1,V1,K2,V2>

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

It can be used instead of the default implementation,


Constructor Summary
MultithreadedMapRunner()
           
 
Method Summary
 void configure(JobConf jobConf)
          Initializes a new instance from a JobConf.
 void run(RecordReader<K1,V1> input, OutputCollector<K2,V2> output, Reporter reporter)
          Start mapping input <key, value> pairs.
 
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 jobConf)
Description copied from interface: JobConfigurable
Initializes a new instance from a JobConf.

Specified by:
configure in interface JobConfigurable
Parameters:
jobConf - the configuration

run

public void run(RecordReader<K1,V1> input,
                OutputCollector<K2,V2> output,
                Reporter reporter)
         throws IOException
Description copied from interface: MapRunnable
Start mapping input <key, value> pairs.

Mapping of input records to output records is complete when this method returns.

Specified by:
run in interface MapRunnable<K1,V1,K2,V2>
Parameters:
input - the RecordReader to read the input records.
output - the OutputCollector to collect the outputrecords.
reporter - Reporter to report progress, status-updates etc.
Throws:
IOException


Copyright © 2014 Apache Software Foundation. All Rights Reserved.