public static class FSMBuilder.FSMReducer extends org.apache.hadoop.mapred.MapReduceBase implements org.apache.hadoop.mapred.Reducer<ChukwaRecordKey,FSMIntermedEntry,ChukwaRecordKey,ChukwaRecord>
Constructor and Description |
---|
FSMReducer() |
Modifier and Type | Method and Description |
---|---|
void |
addStitchingFields(ChukwaRecord cr) |
void |
reduce(ChukwaRecordKey key,
Iterator<FSMIntermedEntry> values,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
public void addStitchingFields(ChukwaRecord cr)
public void reduce(ChukwaRecordKey key, Iterator<FSMIntermedEntry> values, org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output, org.apache.hadoop.mapred.Reporter reporter) throws IOException
reduce
in interface org.apache.hadoop.mapred.Reducer<ChukwaRecordKey,FSMIntermedEntry,ChukwaRecordKey,ChukwaRecord>
IOException
Copyright © 2016 Apache Software Foundation. All Rights Reserved.