Package | Description |
---|---|
org.apache.hadoop.chukwa.analysis.salsa.fsm |
Modifier and Type | Method and Description |
---|---|
FSMIntermedEntry |
FSMIntermedEntry.clone() |
protected FSMIntermedEntry |
JobHistoryTaskDataMapper.populateRecord_MapCounters(FSMIntermedEntry this_rec,
ChukwaRecord val,
ArrayList<String> fieldNamesList) |
protected FSMIntermedEntry |
JobHistoryTaskDataMapper.populateRecord_ReduceCounters(FSMIntermedEntry this_rec,
ChukwaRecord val,
ArrayList<String> fieldNamesList) |
static FSMIntermedEntry |
ParseUtilities.splitChukwaRecordKey(String origkey,
FSMIntermedEntry rec,
String delim) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
JobHistoryTaskDataMapper.expandReduceEnd(ChukwaRecordKey key,
ChukwaRecord val,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,FSMIntermedEntry> output,
org.apache.hadoop.mapred.Reporter reporter,
FSMIntermedEntry this_rec) |
protected boolean |
JobHistoryTaskDataMapper.expandReduceStart(ChukwaRecordKey key,
ChukwaRecord val,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,FSMIntermedEntry> output,
org.apache.hadoop.mapred.Reporter reporter,
FSMIntermedEntry this_rec) |
int |
FSMIntermedEntryPartitioner.getPartition(ChukwaRecordKey key,
FSMIntermedEntry val,
int numPartitions) |
protected FSMIntermedEntry |
JobHistoryTaskDataMapper.populateRecord_MapCounters(FSMIntermedEntry this_rec,
ChukwaRecord val,
ArrayList<String> fieldNamesList) |
protected FSMIntermedEntry |
JobHistoryTaskDataMapper.populateRecord_ReduceCounters(FSMIntermedEntry this_rec,
ChukwaRecord val,
ArrayList<String> fieldNamesList) |
static FSMIntermedEntry |
ParseUtilities.splitChukwaRecordKey(String origkey,
FSMIntermedEntry rec,
String delim) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
JobHistoryTaskDataMapper.expandReduceEnd(ChukwaRecordKey key,
ChukwaRecord val,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,FSMIntermedEntry> output,
org.apache.hadoop.mapred.Reporter reporter,
FSMIntermedEntry this_rec) |
protected boolean |
JobHistoryTaskDataMapper.expandReduceStart(ChukwaRecordKey key,
ChukwaRecord val,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,FSMIntermedEntry> output,
org.apache.hadoop.mapred.Reporter reporter,
FSMIntermedEntry this_rec) |
void |
TaskTrackerClientTraceMapper.map(ChukwaRecordKey key,
ChukwaRecord val,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,FSMIntermedEntry> output,
org.apache.hadoop.mapred.Reporter reporter) |
void |
JobHistoryTaskDataMapper.map(ChukwaRecordKey key,
ChukwaRecord val,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,FSMIntermedEntry> output,
org.apache.hadoop.mapred.Reporter reporter) |
void |
DataNodeClientTraceMapper.map(ChukwaRecordKey key,
ChukwaRecord val,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,FSMIntermedEntry> output,
org.apache.hadoop.mapred.Reporter reporter) |
protected void |
TaskTrackerClientTraceMapper.parseClientTraceDetailed(ChukwaRecordKey key,
ChukwaRecord val,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,FSMIntermedEntry> output,
org.apache.hadoop.mapred.Reporter reporter,
ArrayList<String> fieldNamesList) |
protected void |
DataNodeClientTraceMapper.parseClientTraceDetailed(ChukwaRecordKey key,
ChukwaRecord val,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,FSMIntermedEntry> output,
org.apache.hadoop.mapred.Reporter reporter,
ArrayList<String> fieldNamesList) |
void |
FSMBuilder.FSMReducer.reduce(ChukwaRecordKey key,
Iterator<FSMIntermedEntry> values,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
Copyright © 2015 Apache Software Foundation. All Rights Reserved.