public class TaskTrackerClientTraceMapper extends org.apache.hadoop.mapred.MapReduceBase implements org.apache.hadoop.mapred.Mapper<ChukwaRecordKey,ChukwaRecord,ChukwaRecordKey,FSMIntermedEntry>
Modifier and Type | Field and Description |
---|---|
protected int |
DEFAULT_SHUFFLE_DURATION_MS |
protected static String |
FSM_CRK_ReduceType |
protected static String |
SEP |
Constructor and Description |
---|
TaskTrackerClientTraceMapper() |
Modifier and Type | Method and Description |
---|---|
void |
map(ChukwaRecordKey key,
ChukwaRecord val,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,FSMIntermedEntry> output,
org.apache.hadoop.mapred.Reporter reporter) |
protected void |
parseClientTraceDetailed(ChukwaRecordKey key,
ChukwaRecord val,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,FSMIntermedEntry> output,
org.apache.hadoop.mapred.Reporter reporter,
ArrayList<String> fieldNamesList) |
protected static final String SEP
protected static String FSM_CRK_ReduceType
protected final int DEFAULT_SHUFFLE_DURATION_MS
public void map(ChukwaRecordKey key, ChukwaRecord val, org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,FSMIntermedEntry> output, org.apache.hadoop.mapred.Reporter reporter) throws IOException
map
in interface org.apache.hadoop.mapred.Mapper<ChukwaRecordKey,ChukwaRecord,ChukwaRecordKey,FSMIntermedEntry>
IOException
protected void parseClientTraceDetailed(ChukwaRecordKey key, ChukwaRecord val, org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,FSMIntermedEntry> output, org.apache.hadoop.mapred.Reporter reporter, ArrayList<String> fieldNamesList) throws IOException
IOException
Copyright © ${year} The Apache Software Foundation