public class TezSliceStats extends cascading.stats.FlowSliceStats<TezNodeStats.Kind> implements cascading.stats.ProvidesCounters
Modifier and Type | Class and Description |
---|---|
static class |
TezSliceStats.TezAttempt |
Modifier and Type | Method and Description |
---|---|
void |
addAttempt(java.lang.Object 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() |
TezNodeStats.Kind |
getKind() |
long |
getLastSuccessfulCounterFetchTime() |
cascading.stats.CascadingStats.Status |
getParentStatus() |
long |
getProcessFinishTime() |
java.lang.String |
getProcessNodeID() |
float |
getProcessProgress() |
long |
getProcessRunTime() |
java.lang.String |
getProcessSliceID() |
long |
getProcessStartTime() |
java.lang.String |
getProcessStatus() |
java.lang.String |
getProcessStepID() |
cascading.stats.CascadingStats.Status |
getStatus() |
void |
setCounters(java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.Long>> counters) |
void |
setDiagnostics(java.lang.String diagnostics) |
void |
setFinishTime(long finishTime) |
void |
setLastFetch(long lastFetch) |
void |
setStartTime(long startTime) |
protected void |
setStatus(cascading.stats.CascadingStats.Status status) |
void |
setSubmitTime(long submitTime) |
void |
setSuccessfulAttemptID(java.lang.String successfulAttemptID) |
java.lang.String |
toString() |
public void setSubmitTime(long submitTime)
public void setStartTime(long startTime)
public void setFinishTime(long finishTime)
public void setSuccessfulAttemptID(java.lang.String successfulAttemptID)
public java.lang.String getID()
getID
in class cascading.stats.FlowSliceStats<TezNodeStats.Kind>
public long getProcessStartTime()
getProcessStartTime
in class cascading.stats.FlowSliceStats<TezNodeStats.Kind>
public long getProcessRunTime()
getProcessRunTime
in class cascading.stats.FlowSliceStats<TezNodeStats.Kind>
public long getProcessFinishTime()
getProcessFinishTime
in class cascading.stats.FlowSliceStats<TezNodeStats.Kind>
public void setDiagnostics(java.lang.String diagnostics)
public cascading.stats.CascadingStats.Status getParentStatus()
protected void setStatus(@Nullable cascading.stats.CascadingStats.Status status)
public cascading.stats.CascadingStats.Status getStatus()
getStatus
in class cascading.stats.FlowSliceStats<TezNodeStats.Kind>
public TezNodeStats.Kind getKind()
getKind
in class cascading.stats.FlowSliceStats<TezNodeStats.Kind>
public java.lang.String[] getDiagnostics()
getDiagnostics
in class cascading.stats.FlowSliceStats<TezNodeStats.Kind>
public java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.Long>> getCounters()
getCounters
in class cascading.stats.FlowSliceStats<TezNodeStats.Kind>
public java.lang.String getProcessSliceID()
getProcessSliceID
in class cascading.stats.FlowSliceStats<TezNodeStats.Kind>
public java.lang.String getProcessNodeID()
getProcessNodeID
in class cascading.stats.FlowSliceStats<TezNodeStats.Kind>
public java.lang.String getProcessStepID()
getProcessStepID
in class cascading.stats.FlowSliceStats<TezNodeStats.Kind>
public java.lang.String getProcessStatus()
getProcessStatus
in class cascading.stats.FlowSliceStats<TezNodeStats.Kind>
public float getProcessProgress()
getProcessProgress
in class cascading.stats.FlowSliceStats<TezNodeStats.Kind>
public java.util.Map<java.lang.Integer,cascading.stats.FlowSliceStats.FlowSliceAttempt> getAttempts()
getAttempts
in class cascading.stats.FlowSliceStats<TezNodeStats.Kind>
public void setCounters(@Nullable java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.Long>> counters)
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(java.lang.Object event)
public java.lang.String toString()
toString
in class java.lang.Object
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.