public class HadoopFlowStepJob extends FlowStepJob<JobConf>
blockForCompletedChildDetailDuration, flowStep, flowStepStats, jobConfiguration, pollingInterval, predecessors, statsStoreInterval, stepName, throwable
Constructor and Description |
---|
HadoopFlowStepJob(ClientState clientState,
BaseFlowStep<JobConf> flowStep,
JobConf currentConf) |
Modifier and Type | Method and Description |
---|---|
protected FlowStepStats |
createStepStats(ClientState clientState) |
protected void |
dumpDebugInfo() |
static long |
getJobPollingInterval(JobConf jobConf) |
protected Throwable |
getThrowable() |
protected void |
internalBlockOnStop() |
protected boolean |
internalIsStartedRunning() |
protected String |
internalJobId() |
protected boolean |
internalNonBlockingIsComplete() |
protected boolean |
internalNonBlockingIsSuccessful() |
protected void |
internalNonBlockingStart() |
protected boolean |
isRemoteExecution() |
boolean |
isSuccessful() |
static void |
reportLocalError(Throwable throwable)
Internal method to report errors that happen on hadoop local mode.
|
protected void |
updateNodeStatus(FlowNodeStats flowNodeStats) |
blockOnJob, blockOnPredecessors, blockTillCompleteOrStopped, call, finalizeNodeSliceCapture, getConfig, getStepStats, internalCleanup, isSkipFlowStep, isStarted, setPredecessors, sleepForPollingInterval, start, stop
public HadoopFlowStepJob(ClientState clientState, BaseFlowStep<JobConf> flowStep, JobConf currentConf)
public static long getJobPollingInterval(JobConf jobConf)
protected FlowStepStats createStepStats(ClientState clientState)
createStepStats
in class FlowStepJob<JobConf>
protected void internalBlockOnStop() throws IOException
internalBlockOnStop
in class FlowStepJob<JobConf>
IOException
protected void internalNonBlockingStart() throws IOException
internalNonBlockingStart
in class FlowStepJob<JobConf>
IOException
protected void updateNodeStatus(FlowNodeStats flowNodeStats)
updateNodeStatus
in class FlowStepJob<JobConf>
public boolean isSuccessful()
isSuccessful
in class FlowStepJob<JobConf>
protected boolean internalNonBlockingIsSuccessful() throws IOException
internalNonBlockingIsSuccessful
in class FlowStepJob<JobConf>
IOException
protected boolean isRemoteExecution()
isRemoteExecution
in class FlowStepJob<JobConf>
protected Throwable getThrowable()
getThrowable
in class FlowStepJob<JobConf>
protected String internalJobId()
internalJobId
in class FlowStepJob<JobConf>
protected boolean internalNonBlockingIsComplete() throws IOException
internalNonBlockingIsComplete
in class FlowStepJob<JobConf>
IOException
protected void dumpDebugInfo()
dumpDebugInfo
in class FlowStepJob<JobConf>
protected boolean internalIsStartedRunning()
internalIsStartedRunning
in class FlowStepJob<JobConf>
public static void reportLocalError(Throwable throwable)
throwable
- the throwable to be reported.Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.