public class PipeReducer extends PipeMapRed implements org.apache.hadoop.mapred.Reducer
LOG, outerrThreadsThrowable
Constructor and Description |
---|
PipeReducer() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
configure(org.apache.hadoop.mapred.JobConf job) |
byte[] |
getFieldSeparator()
Returns the field separator to be used.
|
byte[] |
getInputSeparator()
Returns the input separator to be used.
|
int |
getNumOfKeyFields()
Returns the number of key fields.
|
void |
reduce(Object key,
Iterator values,
org.apache.hadoop.mapred.OutputCollector output,
org.apache.hadoop.mapred.Reporter reporter) |
getClientInput, getClientOutput, getConfiguration, getContext, mapRedFinished
public void configure(org.apache.hadoop.mapred.JobConf job)
configure
in interface org.apache.hadoop.mapred.JobConfigurable
configure
in class PipeMapRed
public void reduce(Object key, Iterator values, org.apache.hadoop.mapred.OutputCollector output, org.apache.hadoop.mapred.Reporter reporter) throws IOException
reduce
in interface org.apache.hadoop.mapred.Reducer
IOException
public void close()
close
in interface Closeable
close
in interface AutoCloseable
public byte[] getInputSeparator()
PipeMapRed
getInputSeparator
in class PipeMapRed
public byte[] getFieldSeparator()
PipeMapRed
getFieldSeparator
in class PipeMapRed
public int getNumOfKeyFields()
PipeMapRed
getNumOfKeyFields
in class PipeMapRed
Copyright © 2017 Apache Software Foundation. All Rights Reserved.