public class JoinReducer extends org.apache.hadoop.mapred.MapReduceBase implements org.apache.hadoop.mapred.Reducer<JoinGroupWritable,RecordInfo,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
SpatialOperationConfig
.JoinGroupGroupComparator
and the values should be sorted using JoinGroupKeyComparator
.JoinOutputCommitter
can be used to removed those duplicated joins.Constructor and Description |
---|
JoinReducer() |
Modifier and Type | Method and Description |
---|---|
void |
configure(org.apache.hadoop.mapred.JobConf jobConf) |
void |
reduce(JoinGroupWritable key, java.util.Iterator<RecordInfo> values, org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text> 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 reduce(JoinGroupWritable key, java.util.Iterator<RecordInfo> values, org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text> output, org.apache.hadoop.mapred.Reporter reporter) throws java.io.IOException
reduce
in interface org.apache.hadoop.mapred.Reducer<JoinGroupWritable,RecordInfo,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
java.io.IOException
Copyright © 2016 Oracle and/or its affiliates. All Rights Reserved.