K
- The type of the input keys as read by the internal input formatV
- The type of the input values as read by the internal input formatpublic class JoinMapper<K,V> extends org.apache.hadoop.mapred.MapReduceBase implements org.apache.hadoop.mapred.Mapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.mapred.InputSplit,JoinGroupWritable,RecordInfo>
MultipleInputsFileSplitInputFormat
needs to be set as the job's input format in order to read two different data sets.ConfigParams.PARTITIONING_RESULT
.Partitioning
.Constructor and Description |
---|
JoinMapper() |
Modifier and Type | Method and Description |
---|---|
void |
configure(org.apache.hadoop.mapred.JobConf jobConf) |
void |
map(org.apache.hadoop.io.NullWritable key, org.apache.hadoop.mapred.InputSplit value, org.apache.hadoop.mapred.OutputCollector<JoinGroupWritable,RecordInfo> output, org.apache.hadoop.mapred.Reporter reporter) |
public void configure(org.apache.hadoop.mapred.JobConf jobConf)
configure
in interface org.apache.hadoop.mapred.JobConfigurable
configure
in class org.apache.hadoop.mapred.MapReduceBase
public void map(org.apache.hadoop.io.NullWritable key, org.apache.hadoop.mapred.InputSplit value, org.apache.hadoop.mapred.OutputCollector<JoinGroupWritable,RecordInfo> output, org.apache.hadoop.mapred.Reporter reporter) throws java.io.IOException
map
in interface org.apache.hadoop.mapred.Mapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.mapred.InputSplit,JoinGroupWritable,RecordInfo>
java.io.IOException
Copyright © 2016 Oracle and/or its affiliates. All Rights Reserved.