public class HadoopSliceStats extends FlowSliceStats<HadoopSliceStats.Kind> implements ProvidesCounters
Modifier and Type | Class and Description |
---|---|
static class |
HadoopSliceStats.HadoopAttempt |
static class |
HadoopSliceStats.Kind |
FlowSliceStats.FlowSliceAttempt
Modifier and Type | Method and Description |
---|---|
void |
addAttempt(TaskCompletionEvent event) |
Map<Integer,FlowSliceStats.FlowSliceAttempt> |
getAttempts() |
Collection<String> |
getCounterGroups() |
Map<String,Map<String,Long>> |
getCounters() |
Collection<String> |
getCountersFor(Class<? extends Enum> group) |
Collection<String> |
getCountersFor(String group) |
long |
getCounterValue(Enum counter) |
long |
getCounterValue(String group,
String name) |
String[] |
getDiagnostics() |
String |
getID() |
HadoopSliceStats.Kind |
getKind() |
long |
getLastSuccessfulCounterFetchTime() |
CascadingStats.Status |
getParentStatus() |
long |
getProcessFinishTime() |
String |
getProcessNodeID() |
float |
getProcessProgress() |
String |
getProcessSliceID() |
long |
getProcessStartTime() |
String |
getProcessStatus() |
String |
getProcessStepID() |
CascadingStats.Status |
getStatus() |
int |
getTaskIDNum() |
protected TaskReport |
getTaskReport() |
void |
setLastFetch(long lastFetch) |
String |
toString() |
getProcessID, getProcessPendingTime, getProcessRunTime, getProcessSubmitTime
public String getID()
getID
in class FlowSliceStats<HadoopSliceStats.Kind>
public HadoopSliceStats.Kind getKind()
getKind
in class FlowSliceStats<HadoopSliceStats.Kind>
public String getProcessSliceID()
getProcessSliceID
in class FlowSliceStats<HadoopSliceStats.Kind>
public int getTaskIDNum()
public String getProcessNodeID()
getProcessNodeID
in class FlowSliceStats<HadoopSliceStats.Kind>
public String getProcessStepID()
getProcessStepID
in class FlowSliceStats<HadoopSliceStats.Kind>
protected TaskReport getTaskReport()
public String getProcessStatus()
getProcessStatus
in class FlowSliceStats<HadoopSliceStats.Kind>
public float getProcessProgress()
getProcessProgress
in class FlowSliceStats<HadoopSliceStats.Kind>
public long getProcessStartTime()
getProcessStartTime
in class FlowSliceStats<HadoopSliceStats.Kind>
public long getProcessFinishTime()
getProcessFinishTime
in class FlowSliceStats<HadoopSliceStats.Kind>
public CascadingStats.Status getParentStatus()
public CascadingStats.Status getStatus()
getStatus
in class FlowSliceStats<HadoopSliceStats.Kind>
public String[] getDiagnostics()
getDiagnostics
in class FlowSliceStats<HadoopSliceStats.Kind>
public Map<String,Map<String,Long>> getCounters()
getCounters
in class FlowSliceStats<HadoopSliceStats.Kind>
public Map<Integer,FlowSliceStats.FlowSliceAttempt> getAttempts()
getAttempts
in class FlowSliceStats<HadoopSliceStats.Kind>
public void setLastFetch(long lastFetch)
public long getLastSuccessfulCounterFetchTime()
getLastSuccessfulCounterFetchTime
in interface ProvidesCounters
public Collection<String> getCounterGroups()
getCounterGroups
in interface ProvidesCounters
public Collection<String> getCountersFor(String group)
getCountersFor
in interface ProvidesCounters
public Collection<String> getCountersFor(Class<? extends Enum> group)
getCountersFor
in interface ProvidesCounters
public long getCounterValue(Enum counter)
getCounterValue
in interface ProvidesCounters
public long getCounterValue(String group, String name)
getCounterValue
in interface ProvidesCounters
public void addAttempt(TaskCompletionEvent event)
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.