public class TezSliceStats extends FlowSliceStats<TezNodeStats.Kind> implements ProvidesCounters
Modifier and Type | Class and Description |
---|---|
static class |
TezSliceStats.TezAttempt |
FlowSliceStats.FlowSliceAttempt
Modifier and Type | Method and Description |
---|---|
void |
addAttempt(java.lang.Object event) |
java.util.Map<java.lang.Integer,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() |
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() |
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(CascadingStats.Status status) |
void |
setSubmitTime(long submitTime) |
void |
setSuccessfulAttemptID(java.lang.String successfulAttemptID) |
java.lang.String |
toString() |
getProcessID, getProcessPendingTime, getProcessSubmitTime
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 FlowSliceStats<TezNodeStats.Kind>
public long getProcessStartTime()
getProcessStartTime
in class FlowSliceStats<TezNodeStats.Kind>
public long getProcessRunTime()
getProcessRunTime
in class FlowSliceStats<TezNodeStats.Kind>
public long getProcessFinishTime()
getProcessFinishTime
in class FlowSliceStats<TezNodeStats.Kind>
public void setDiagnostics(java.lang.String diagnostics)
public CascadingStats.Status getParentStatus()
protected void setStatus(@Nullable CascadingStats.Status status)
public CascadingStats.Status getStatus()
getStatus
in class FlowSliceStats<TezNodeStats.Kind>
public TezNodeStats.Kind getKind()
getKind
in class FlowSliceStats<TezNodeStats.Kind>
public java.lang.String[] getDiagnostics()
getDiagnostics
in class FlowSliceStats<TezNodeStats.Kind>
public java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.Long>> getCounters()
getCounters
in class FlowSliceStats<TezNodeStats.Kind>
public java.lang.String getProcessSliceID()
getProcessSliceID
in class FlowSliceStats<TezNodeStats.Kind>
public java.lang.String getProcessNodeID()
getProcessNodeID
in class FlowSliceStats<TezNodeStats.Kind>
public java.lang.String getProcessStepID()
getProcessStepID
in class FlowSliceStats<TezNodeStats.Kind>
public java.lang.String getProcessStatus()
getProcessStatus
in class FlowSliceStats<TezNodeStats.Kind>
public float getProcessProgress()
getProcessProgress
in class FlowSliceStats<TezNodeStats.Kind>
public java.util.Map<java.lang.Integer,FlowSliceStats.FlowSliceAttempt> getAttempts()
getAttempts
in class 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 ProvidesCounters
public java.util.Collection<java.lang.String> getCounterGroups()
getCounterGroups
in interface ProvidesCounters
public java.util.Collection<java.lang.String> getCountersFor(java.lang.String group)
getCountersFor
in interface ProvidesCounters
public java.util.Collection<java.lang.String> getCountersFor(java.lang.Class<? extends java.lang.Enum> group)
getCountersFor
in interface ProvidesCounters
public long getCounterValue(java.lang.Enum counter)
getCounterValue
in interface ProvidesCounters
public long getCounterValue(java.lang.String group, java.lang.String name)
getCounterValue
in interface ProvidesCounters
public void addAttempt(java.lang.Object event)
public java.lang.String toString()
toString
in class java.lang.Object
Copyright © 2007-2017 Cascading Maintainers. All Rights Reserved.