public abstract class BaseCachedStepStats<Configuration,JobStatusClient,Counters> extends FlowStepStats
CascadingStats.Status, CascadingStats.Type
Modifier and Type | Field and Description |
---|---|
protected CounterCache<Configuration,JobStatusClient,Counters> |
counterCache |
clientState, finishedTime, lastCaptureDetail, listeners, name, pendingTime, runTime, startTime, STATS_COMPLETE_CHILD_DETAILS_BLOCK_DURATION, STATS_STORE_INTERVAL, status, submitTime, throwable, throwableTrace
Constructor and Description |
---|
BaseCachedStepStats(FlowStep flowStep,
ClientState clientState) |
Modifier and Type | Method and Description |
---|---|
protected Counters |
cachedCounters(boolean force) |
Collection<String> |
getCounterGroups()
Method getCounterGroups returns all of the Hadoop counter groups.
|
Collection<String> |
getCounterGroupsMatching(String regex)
Method getCounterGroupsMatching returns all the Hadoop counter groups that match the give regex pattern.
|
Collection<String> |
getCountersFor(String group)
Method getCountersFor returns the Hadoop counters for the given group.
|
long |
getCounterValue(Enum counter)
Method getCounterValue returns the Hadoop counter value for the given counter enum.
|
long |
getCounterValue(String group,
String counter)
Method getCounterValue returns the Hadoop counter value for the given group and counter name.
|
abstract JobStatusClient |
getJobStatusClient()
Method getRunningJob returns the Hadoop
RunningJob managing this Hadoop job. |
long |
getLastSuccessfulCounterFetchTime()
Method getLastSuccessfulCounterFetchTime returns the time, in millis, the last moment counters
were successfully retrieved.
|
void |
recordChildStats()
Synchronized to prevent state changes mid record, #stop may be called out of band
|
addNodeStats, getChildren, getChildWith, getFlowNodeIDs, getFlowNodeStats, getFlowNodeStatsMap, getFlowStep, getID, getNodesCount, getProcessLogger, getProcessStatusURL, getProcessStepID, getType, hasCapturedFinalDetail, recordInfo, toString
addListener, captureDetail, 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
protected CounterCache<Configuration,JobStatusClient,Counters> counterCache
public BaseCachedStepStats(FlowStep flowStep, ClientState clientState)
public abstract JobStatusClient getJobStatusClient()
RunningJob
managing this Hadoop job.public long getLastSuccessfulCounterFetchTime()
ProvidesCounters
CascadingStats.getFinishedTime()
it is likely the
counter service became unavailable.public Collection<String> getCounterGroups()
public Collection<String> getCounterGroupsMatching(String regex)
getCounterGroupsMatching
in class CascadingStats<FlowNodeStats>
regex
- of Stringpublic Collection<String> getCountersFor(String group)
group
- of Stringpublic long getCounterValue(Enum counter)
counter
- of Enumpublic long getCounterValue(String group, String counter)
group
- of Stringcounter
- of Stringprotected Counters cachedCounters(boolean force)
public void recordChildStats()
recordChildStats
in class FlowStepStats
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.