public class ProcessStepStats extends FlowStepStats
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 |
---|
ProcessStepStats(ClientState clientState,
Map<String,Map<String,Long>> counters,
ProcessFlowStep step)
Constructs a new ProcessStepStats instance.
|
Modifier and Type | Method and Description |
---|---|
void |
captureDetail()
Method captureDetail will recursively capture details about nested systems.
|
void |
captureDetail(CascadingStats.Type depth) |
Collection |
getChildren()
Method getChildren returns any relevant child statistics instances.
|
Collection<String> |
getCounterGroups()
Method getCounterGroups returns all the available counter group names.
|
Collection<String> |
getCounterGroupsMatching(String regex)
Method getCounterGroupsMatching returns all the available counter group names that match
the given regular expression.
|
Collection<String> |
getCountersFor(String group)
Method getCountersFor returns all the counter names for the give group name.
|
long |
getCounterValue(Enum counter)
Method getCounter returns the current value for the given counter Enum.
|
long |
getCounterValue(String group,
String counter)
Method getCounter returns the current value for the given group and counter.
|
long |
getLastSuccessfulCounterFetchTime()
Method getLastSuccessfulCounterFetchTime returns the time, in millis, the last moment counters
were successfully retrieved.
|
String |
getProcessStepID()
Method getProcessStepID returns the ID representing the under platform process.
|
void |
recordChildStats()
An internal method that will refresh current counters and, if a clientState client is enabled, the child details
including node and slice statistics.
|
addNodeStats, getChildWith, getFlowNodeIDs, getFlowNodeStats, getFlowNodeStatsMap, getFlowStep, getID, getNodesCount, getProcessLogger, getProcessStatusURL, getType, hasCapturedFinalDetail, recordInfo, toString
addListener, 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 ProcessStepStats(ClientState clientState, Map<String,Map<String,Long>> counters, ProcessFlowStep step)
clientState
- counters
- step
- public void recordChildStats()
FlowStepStats
CascadingStats.captureDetail()
to force all statistics to be cached and locally accessible.recordChildStats
in class FlowStepStats
public String getProcessStepID()
FlowStepStats
getProcessStepID
in class FlowStepStats
public long getLastSuccessfulCounterFetchTime()
ProvidesCounters
CascadingStats.getFinishedTime()
it is likely the
counter service became unavailable.public Collection<String> getCounterGroups()
ProvidesCounters
public Collection<String> getCountersFor(String group)
ProvidesCounters
public long getCounterValue(Enum counter)
ProvidesCounters
counter
- of type Enumpublic long getCounterValue(String group, String counter)
ProvidesCounters
group
- of type Stringcounter
- of type Stringpublic void captureDetail()
CascadingStats
captureDetail
in class CascadingStats<FlowNodeStats>
public void captureDetail(CascadingStats.Type depth)
captureDetail
in class CascadingStats<FlowNodeStats>
public Collection<String> getCounterGroupsMatching(String regex)
CascadingStats
getCounterGroupsMatching
in class CascadingStats<FlowNodeStats>
regex
- of type Stringpublic Collection getChildren()
CascadingStats
getChildren
in class FlowStepStats
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.