public abstract class HadoopStepStats extends cascading.stats.BaseCachedStepStats<Configuration,RunningJob,Counters>
Modifier | Constructor and Description |
---|---|
protected |
HadoopStepStats(cascading.flow.FlowStep<JobConf> flowStep,
cascading.management.state.ClientState clientState) |
Modifier and Type | Method and Description |
---|---|
void |
captureDetail(cascading.stats.CascadingStats.Type depth)
Method captureDetail captures statistics task details and completion events.
|
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.
|
java.lang.String |
getProcessStepID()
Method getProcessStepID returns the Hadoop running job JobID.
|
float |
getReduceProgress()
Returns the underlying Reduce tasks progress percentage.
|
java.lang.String |
getStatusURL() |
cachedCounters, getCounterGroups, getCounterGroupsMatching, getCountersFor, getCounterValue, getCounterValue, getJobStatusClient, getLastSuccessfulCounterFetchTime, recordChildStats
addNodeStats, getChildren, getChildWith, getFlowNodeIDs, getFlowNodeStats, getFlowNodeStatsMap, getFlowStep, getID, getNodesCount, getProcessLogger, getProcessStatusURL, getType, hasCapturedFinalDetail, recordInfo, 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
protected HadoopStepStats(cascading.flow.FlowStep<JobConf> flowStep, cascading.management.state.ClientState clientState)
public int getNumMapTasks()
public int getNumReduceTasks()
public java.lang.String getProcessStepID()
getProcessStepID
in class cascading.stats.FlowStepStats
public abstract JobClient getJobClient()
JobClient
managing this Hadoop job.public float getMapProgress()
public float getReduceProgress()
public java.lang.String getStatusURL()
public void captureDetail(cascading.stats.CascadingStats.Type depth)
captureDetail
in class cascading.stats.CascadingStats<cascading.stats.FlowNodeStats>
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.