public class PipeMapper extends PipeMapRed implements org.apache.hadoop.mapred.Mapper
LOG, outerrThreadsThrowable
Constructor and Description |
---|
PipeMapper() |
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 |
map(Object key,
Object value,
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 map(Object key, Object value, org.apache.hadoop.mapred.OutputCollector output, org.apache.hadoop.mapred.Reporter reporter) throws IOException
map
in interface org.apache.hadoop.mapred.Mapper
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 © 2015 Apache Software Foundation. All Rights Reserved.