public abstract class DataJoinMapperBase extends JobBase
Modifier and Type | Field and Description |
---|---|
protected String |
inputFile |
protected org.apache.hadoop.io.Text |
inputTag |
protected org.apache.hadoop.mapred.JobConf |
job |
protected org.apache.hadoop.mapred.Reporter |
reporter |
Constructor and Description |
---|
DataJoinMapperBase() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
configure(org.apache.hadoop.mapred.JobConf job)
Initializes a new instance from a
JobConf . |
protected abstract org.apache.hadoop.io.Text |
generateGroupKey(TaggedMapOutput aRecord)
Generate a map output key.
|
protected abstract org.apache.hadoop.io.Text |
generateInputTag(String inputFile)
Determine the source tag based on the input file name.
|
protected abstract TaggedMapOutput |
generateTaggedMapOutput(Object value)
Generate a tagged map output value.
|
void |
map(Object key,
Object value,
org.apache.hadoop.mapred.OutputCollector output,
org.apache.hadoop.mapred.Reporter reporter) |
void |
reduce(Object arg0,
Iterator arg1,
org.apache.hadoop.mapred.OutputCollector arg2,
org.apache.hadoop.mapred.Reporter arg3) |
addDoubleValue, addLongValue, getDoubleValue, getLongValue, getReport, report, setDoubleValue, setLongValue
protected String inputFile
protected org.apache.hadoop.mapred.JobConf job
protected org.apache.hadoop.io.Text inputTag
protected org.apache.hadoop.mapred.Reporter reporter
public void configure(org.apache.hadoop.mapred.JobConf job)
JobBase
JobConf
.protected abstract org.apache.hadoop.io.Text generateInputTag(String inputFile)
inputFile
- protected abstract TaggedMapOutput generateTaggedMapOutput(Object value)
value
- protected abstract org.apache.hadoop.io.Text generateGroupKey(TaggedMapOutput aRecord)
aRecord
- public void map(Object key, Object value, org.apache.hadoop.mapred.OutputCollector output, org.apache.hadoop.mapred.Reporter reporter) throws IOException
IOException
public void close() throws IOException
IOException
public void reduce(Object arg0, Iterator arg1, org.apache.hadoop.mapred.OutputCollector arg2, org.apache.hadoop.mapred.Reporter arg3) throws IOException
IOException
Copyright © 2015 Apache Software Foundation. All Rights Reserved.