public static class FSMBuilder.FSMReducer extends org.apache.hadoop.mapred.MapReduceBase implements org.apache.hadoop.mapred.Reducer<ChukwaRecordKey,FSMIntermedEntry,ChukwaRecordKey,ChukwaRecord>
Modifier and Type | Field and Description |
---|---|
protected static String |
JCDF_EDGE_TIME |
protected static String |
JCDF_EDGE_VOL |
protected static String |
JCDF_ID1 |
protected static String |
JCDF_ID2 |
protected static String |
JCDF_SEP |
Constructor and Description |
---|
FSMReducer() |
Modifier and Type | Method and Description |
---|---|
protected void |
addStitchingFields_blockread(ChukwaRecord cr,
ArrayList<String> fnl)
Populates fields used by Pig script for stitching together causal flows
|
protected void |
addStitchingFields_blockwrite(ChukwaRecord cr,
ArrayList<String> fnl) |
protected void |
addStitchingFields_map(ChukwaRecord cr,
ArrayList<String> fnl)
Populates fields used by Pig script for stitching together causal flows
|
protected void |
addStitchingFields_redreducer(ChukwaRecord cr,
ArrayList<String> fnl)
Populates fields used by Pig script for stitching together causal flows
|
protected void |
addStitchingFields_redshufwait(ChukwaRecord cr,
ArrayList<String> fnl)
Populates fields used by Pig script for stitching together causal flows
|
protected void |
addStitchingFields_redsort(ChukwaRecord cr,
ArrayList<String> fnl)
Populates fields used by Pig script for stitching together causal flows
|
protected void |
addStitchingFields_shuffle(ChukwaRecord cr,
ArrayList<String> fnl)
Populates fields used by Pig script for stitching together causal flows
|
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) |
protected static final String JCDF_ID1
protected static final String JCDF_ID2
protected static final String JCDF_EDGE_TIME
protected static final String JCDF_EDGE_VOL
protected static final String JCDF_SEP
protected void addStitchingFields_blockread(ChukwaRecord cr, ArrayList<String> fnl)
protected void addStitchingFields_map(ChukwaRecord cr, ArrayList<String> fnl)
protected void addStitchingFields_shuffle(ChukwaRecord cr, ArrayList<String> fnl)
protected void addStitchingFields_redshufwait(ChukwaRecord cr, ArrayList<String> fnl)
protected void addStitchingFields_redsort(ChukwaRecord cr, ArrayList<String> fnl)
protected void addStitchingFields_redreducer(ChukwaRecord cr, ArrayList<String> fnl)
protected void addStitchingFields_blockwrite(ChukwaRecord cr, ArrayList<String> fnl)
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 © 2015 Apache Software Foundation. All Rights Reserved.