public class CascadeStats extends CascadingStats<FlowStats>
Cascade
specific statistics.CascadingStats.Status, CascadingStats.Type
clientState, finishedTime, lastCaptureDetail, listeners, name, pendingTime, runTime, startTime, STATS_COMPLETE_CHILD_DETAILS_BLOCK_DURATION, STATS_STORE_INTERVAL, status, submitTime, throwable, throwableTrace
Constructor and Description |
---|
CascadeStats(Cascade cascade,
ClientState clientState) |
Modifier and Type | Method and Description |
---|---|
void |
addFlowStats(FlowStats flowStats)
Method addFlowStats add a child
Flow {2link FlowStats} instance. |
void |
captureDetail(CascadingStats.Type depth) |
Cascade |
getCascade() |
java.util.Collection<FlowStats> |
getChildren()
Method getChildren returns any relevant child statistics instances.
|
FlowStats |
getChildWith(java.lang.String id)
Method getChildWith returns a child stats instance with the given ID value.
|
java.util.Collection<java.lang.String> |
getCounterGroups()
Method getCounterGroups returns all the available counter group names.
|
java.util.Collection<java.lang.String> |
getCounterGroupsMatching(java.lang.String regex)
Method getCounterGroupsMatching returns all the available counter group names that match
the given regular expression.
|
java.util.Collection<java.lang.String> |
getCountersFor(java.lang.String group)
Method getCountersFor returns all the counter names for the give group name.
|
long |
getCounterValue(java.lang.Enum counter)
Method getCounter returns the current value for the given counter Enum.
|
long |
getCounterValue(java.lang.String group,
java.lang.String counter)
Method getCounter returns the current value for the given group and counter.
|
int |
getFlowCount()
Method getFlowCount returns the number of
Flow s executed by the Cascade. |
java.lang.String |
getID()
Method getID returns the ID of this CascadingStats object.
|
long |
getLastSuccessfulCounterFetchTime()
Method getLastSuccessfulCounterFetchTime returns the time, in millis, the last moment counters
were successfully retrieved.
|
protected ProcessLogger |
getProcessLogger() |
CascadingStats.Type |
getType() |
void |
recordInfo() |
java.lang.String |
toString() |
addListener, captureDetail, cleanup, fireListeners, getCountersFor, getCurrentDuration, getDuration, getFinishedTime, getName, getPendingTime, getPrefix, getRunTime, getStartTime, getStatsString, getStatus, getSubmitTime, getThrowable, getThrowableTrace, isDetailStale, isEngaged, isFailed, isFinished, isPending, isRunning, isSkipped, isStarted, isStopped, isSubmitted, isSuccessful, logDebug, logError, logError, logInfo, logWarn, markDetailCaptured, markFailed, markFailed, markFailed, markFailed, markFinishedTime, markPending, markPendingTime, markRunning, markRunTime, markSkipped, markStarted, markStartedThenRunning, markStartTime, markStartToRunTime, markStopped, markSubmitted, markSubmitTime, markSuccessful, prepare, recordStats, removeListener, setStatsStoreInterval
public CascadeStats(Cascade cascade, ClientState clientState)
protected ProcessLogger getProcessLogger()
getProcessLogger
in class CascadingStats<FlowStats>
public java.lang.String getID()
CascadingStats
getID
in class CascadingStats<FlowStats>
public CascadingStats.Type getType()
getType
in class CascadingStats<FlowStats>
public Cascade getCascade()
public void recordInfo()
recordInfo
in class CascadingStats<FlowStats>
public void addFlowStats(FlowStats flowStats)
Flow
{2link FlowStats} instance.flowStats
- of type FlowStatspublic int getFlowCount()
Flow
s executed by the Cascade.public long getLastSuccessfulCounterFetchTime()
ProvidesCounters
If -1, counter values were never successfully retrieved.
If this return value is less than the CascadingStats.getFinishedTime()
it is likely the
counter service became unavailable.
public java.util.Collection<java.lang.String> getCounterGroups()
ProvidesCounters
public java.util.Collection<java.lang.String> getCounterGroupsMatching(java.lang.String regex)
CascadingStats
getCounterGroupsMatching
in class CascadingStats<FlowStats>
regex
- of type Stringpublic java.util.Collection<java.lang.String> getCountersFor(java.lang.String group)
ProvidesCounters
public long getCounterValue(java.lang.Enum counter)
ProvidesCounters
counter
- of type Enumpublic long getCounterValue(java.lang.String group, java.lang.String counter)
ProvidesCounters
group
- of type Stringcounter
- of type Stringpublic void captureDetail(CascadingStats.Type depth)
captureDetail
in class CascadingStats<FlowStats>
public java.util.Collection<FlowStats> getChildren()
CascadingStats
getChildren
in class CascadingStats<FlowStats>
public FlowStats getChildWith(java.lang.String id)
CascadingStats
getChildWith
in class CascadingStats<FlowStats>
id
- the id of a child instancepublic java.lang.String toString()
toString
in class CascadingStats<FlowStats>
Copyright © 2007-2017 Cascading Maintainers. All Rights Reserved.