org.apache.hadoop.streaming
Class PipeMapRunner<K1,V1,K2,V2>

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

public class PipeMapRunner<K1,V1,K2,V2>
extends org.apache.hadoop.mapred.MapRunner<K1,V1,K2,V2>


Constructor Summary
PipeMapRunner()
           
 
Method Summary
 void run(org.apache.hadoop.mapred.RecordReader<K1,V1> input, org.apache.hadoop.mapred.OutputCollector<K2,V2> output, org.apache.hadoop.mapred.Reporter reporter)
           
 
Methods inherited from class org.apache.hadoop.mapred.MapRunner
configure, getMapper
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

PipeMapRunner

public PipeMapRunner()
Method Detail

run

public void run(org.apache.hadoop.mapred.RecordReader<K1,V1> input,
                org.apache.hadoop.mapred.OutputCollector<K2,V2> output,
                org.apache.hadoop.mapred.Reporter reporter)
         throws IOException
Specified by:
run in interface org.apache.hadoop.mapred.MapRunnable<K1,V1,K2,V2>
Overrides:
run in class org.apache.hadoop.mapred.MapRunner<K1,V1,K2,V2>
Throws:
IOException


Copyright © 2014 Apache Software Foundation. All Rights Reserved.