public class PipeMapRunner<K1,V1,K2,V2>
extends org.apache.hadoop.mapred.MapRunner<K1,V1,K2,V2>
Constructor and Description |
---|
PipeMapRunner() |
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
Copyright © 2017 Apache Software Foundation. All Rights Reserved.