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
getProcessID, getProcessPendingTime, getProcessRunTime, getProcessSubmitTime
public void update(CascadingStats.Status parentStatus, HadoopSliceStats.Kind kind, TaskReport taskReport, long lastFetch)
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 float getProgress()
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.