edu.stolaf.cs.wmrserver.streaming
Class PipeMapRunner<K1,V1,K2,V2>

java.lang.Object
  extended by org.apache.hadoop.mapred.MapRunner<K1,V1,K2,V2>
      extended by edu.stolaf.cs.wmrserver.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 java.io.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:
java.io.IOException