public abstract class HadoopStepStats extends BaseHadoopStepStats<RunningJob,Counters>
CascadingStats.Status, CascadingStats.Type
counterCache
clientState, STATS_COMPLETE_CHILD_DETAILS_BLOCK_DURATION, STATS_STORE_INTERVAL
Modifier | Constructor and Description |
---|---|
protected |
HadoopStepStats(FlowStep<JobConf> flowStep,
ClientState clientState) |
Modifier and Type | Method and Description |
---|---|
void |
captureDetail(CascadingStats.Type depth)
Method captureDetail captures statistics task details and completion events.
|
protected static Job |
getJob(RunningJob runningJob) |
abstract JobClient |
getJobClient()
Method getJobClient returns the Hadoop
JobClient managing this Hadoop job. |
float |
getMapProgress()
Returns the underlying Map tasks progress percentage.
|
int |
getNumMapTasks()
Method getNumMapTasks returns the numMapTasks from the Hadoop job file.
|
int |
getNumReduceTasks()
Method getNumReduceTasks returns the numReducerTasks from the Hadoop job file.
|
String |
getProcessStatusURL() |
String |
getProcessStepID() |
float |
getReduceProgress()
Returns the underlying Reduce tasks progress percentage.
|
String |
getStatusURL()
Deprecated.
|
cachedCounters, getCounterGroups, getCounterGroupsMatching, getCountersFor, getCounterValue, getCounterValue, getJobStatusClient, getLastSuccessfulCounterFetchTime, recordChildStats
addNodeStats, getChildren, getChildWith, getFlowNodeIDs, getFlowNodeStats, getFlowNodeStatsMap, getFlowStep, getID, getNodesCount, getProcessLogger, getType, hasCapturedFinalDetail, recordInfo, toString
addListener, captureDetail, cleanup, fireListeners, getCountersFor, getCurrentDuration, getDuration, getFinishedTime, getName, getPendingTime, 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, markPending, markPendingTime, markRunning, markRunTime, markSkipped, markStarted, markStartedThenRunning, markStartTime, markStartToRunTime, markStopped, markSubmitted, markSubmitTime, markSuccessful, prepare, recordStats, removeListener, setStatsStoreInterval
protected HadoopStepStats(FlowStep<JobConf> flowStep, ClientState clientState)
protected static Job getJob(RunningJob runningJob)
public int getNumMapTasks()
public int getNumReduceTasks()
public String getProcessStepID()
getProcessStepID
in class FlowStepStats
public abstract JobClient getJobClient()
JobClient
managing this Hadoop job.public float getMapProgress()
public float getReduceProgress()
public String getProcessStatusURL()
getProcessStatusURL
in class FlowStepStats
@Deprecated public String getStatusURL()
getProcessStatusURL()
public void captureDetail(CascadingStats.Type depth)
captureDetail
in class CascadingStats<FlowNodeStats>
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.