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