cascading.stats.hadoop
Class HadoopStepStats
java.lang.Object
cascading.stats.CascadingStats
cascading.stats.FlowStepStats
cascading.stats.hadoop.BaseHadoopStepStats
cascading.stats.hadoop.HadoopStepStats
- All Implemented Interfaces:
- Serializable
public abstract class HadoopStepStats
- extends BaseHadoopStepStats
Hadoop 1 specific sub-class of BaseHadoopStats using the mapred API.
- See Also:
- Serialized Form
Methods inherited from class cascading.stats.hadoop.BaseHadoopStepStats |
cachedCounters, cachedCounters, captureDetail, captureDetail, getChildIDs, getChildren, getCounterGroups, getCounterGroupsMatching, getCountersFor, getCounterValue, getCounterValue, getJobClient, getJobID, getMapProgress, getNumMapTasks, getNumReduceTasks, getReduceProgress, getRunningJob, getStatusURL, getTaskStats, recordChildStats, setTaskStats |
Methods inherited from class cascading.stats.CascadingStats |
cleanup, getCountersFor, getCurrentDuration, getDuration, getFinishedTime, getName, getPendingTime, getRunTime, getStartTime, getStatsString, getStatus, getSubmitTime, getThrowable, isEngaged, isFailed, isFinished, isPending, isRunning, isSkipped, isStarted, isStopped, isSubmitted, isSuccessful, markFailed, markPending, markPendingTime, markRunning, markRunTime, markSkipped, markStarted, markStartedThenRunning, markStartTime, markStartToRunTime, markStopped, markSubmitted, markSubmitTime, markSuccessful, prepare, recordStats, setStatsStoreInterval |
HadoopStepStats
protected HadoopStepStats(FlowStep<JobConf> flowStep,
ClientState clientState)
addTaskStats
protected void addTaskStats(Map<String,HadoopSliceStats> taskStats,
HadoopSliceStats.Kind kind,
boolean skipLast)
throws IOException
- Specified by:
addTaskStats
in class BaseHadoopStepStats
- Throws:
IOException
addAttemptsToTaskStats
protected void addAttemptsToTaskStats(Map<String,HadoopSliceStats> taskStats,
boolean captureAttempts)
- Specified by:
addAttemptsToTaskStats
in class BaseHadoopStepStats
Copyright © 2007-2014 Concurrent, Inc. All Rights Reserved.