public class FlowStats extends CascadingStats<FlowStepStats>
Flow
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 |
---|
FlowStats(Flow flow,
ClientState clientState) |
Modifier and Type | Method and Description |
---|---|
void |
addStepStats(FlowStepStats flowStepStats) |
void |
captureDetail(CascadingStats.Type depth) |
boolean |
equals(java.lang.Object object) |
java.lang.String |
getAppID() |
java.lang.String |
getAppName() |
java.util.Collection<FlowStepStats> |
getChildren()
Method getChildren returns any relevant child statistics instances.
|
FlowStepStats |
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.
|
Flow |
getFlow() |
java.util.Map<java.lang.Object,java.lang.Object> |
getFlowProperties() |
java.util.List<FlowStepStats> |
getFlowStepStats()
Method getStepStats returns the stepStats owned by this FlowStats.
|
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() |
protected java.lang.String |
getStatsString() |
int |
getStepsCount()
Method getStepsCount returns the number of steps this Flow executed.
|
CascadingStats.Type |
getType() |
int |
hashCode() |
void |
recordInfo() |
java.lang.String |
toString() |
addListener, captureDetail, cleanup, fireListeners, getCountersFor, getCurrentDuration, getDuration, getFinishedTime, getName, getPendingTime, getPrefix, getRunTime, getStartTime, 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 FlowStats(Flow flow, ClientState clientState)
protected ProcessLogger getProcessLogger()
getProcessLogger
in class CascadingStats<FlowStepStats>
public java.util.Map<java.lang.Object,java.lang.Object> getFlowProperties()
public java.lang.String getAppID()
public java.lang.String getAppName()
public java.lang.String getID()
CascadingStats
getID
in class CascadingStats<FlowStepStats>
public CascadingStats.Type getType()
getType
in class CascadingStats<FlowStepStats>
public void recordInfo()
recordInfo
in class CascadingStats<FlowStepStats>
public void addStepStats(FlowStepStats flowStepStats)
public java.util.List<FlowStepStats> getFlowStepStats()
public int getStepsCount()
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<FlowStepStats>
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<FlowStepStats>
public java.util.Collection<FlowStepStats> getChildren()
CascadingStats
getChildren
in class CascadingStats<FlowStepStats>
public FlowStepStats getChildWith(java.lang.String id)
CascadingStats
getChildWith
in class CascadingStats<FlowStepStats>
id
- the id of a child instanceprotected java.lang.String getStatsString()
getStatsString
in class CascadingStats<FlowStepStats>
public java.lang.String toString()
toString
in class CascadingStats<FlowStepStats>
public int hashCode()
hashCode
in class java.lang.Object
public boolean equals(java.lang.Object object)
equals
in class java.lang.Object
Copyright © 2007-2017 Cascading Maintainers. All Rights Reserved.