public class HadoopFlowStepJob extends cascading.flow.planner.FlowStepJob<JobConf>
Modifier and Type | Field and Description |
---|---|
protected JobClient |
jobClient
Field jobClient
|
protected RunningJob |
runningJob
Field runningJob
|
Constructor and Description |
---|
HadoopFlowStepJob(cascading.management.state.ClientState clientState,
cascading.flow.planner.BaseFlowStep<JobConf> flowStep,
JobConf currentConf) |
Modifier and Type | Method and Description |
---|---|
protected cascading.stats.FlowStepStats |
createStepStats(cascading.management.state.ClientState clientState) |
protected void |
dumpDebugInfo() |
static long |
getJobPollingInterval(JobConf jobConf) |
protected java.lang.Throwable |
getThrowable() |
protected void |
internalBlockOnStop() |
protected boolean |
internalIsStartedRunning() |
protected java.lang.String |
internalJobId() |
protected boolean |
internalNonBlockingIsComplete() |
protected boolean |
internalNonBlockingIsSuccessful() |
protected void |
internalNonBlockingStart() |
protected RunningJob |
internalNonBlockingSubmit() |
protected boolean |
isRemoteExecution() |
boolean |
isSuccessful() |
static void |
reportLocalError(java.lang.Throwable throwable)
Internal method to report errors that happen on hadoop local mode.
|
protected void |
updateNodeStatus(cascading.stats.FlowNodeStats flowNodeStats) |
protected RunningJob runningJob
public HadoopFlowStepJob(cascading.management.state.ClientState clientState, cascading.flow.planner.BaseFlowStep<JobConf> flowStep, JobConf currentConf)
public static long getJobPollingInterval(JobConf jobConf)
protected cascading.stats.FlowStepStats createStepStats(cascading.management.state.ClientState clientState)
createStepStats
in class cascading.flow.planner.FlowStepJob<JobConf>
protected void internalBlockOnStop() throws java.io.IOException
internalBlockOnStop
in class cascading.flow.planner.FlowStepJob<JobConf>
java.io.IOException
protected void internalNonBlockingStart() throws java.io.IOException
internalNonBlockingStart
in class cascading.flow.planner.FlowStepJob<JobConf>
java.io.IOException
protected RunningJob internalNonBlockingSubmit() throws java.io.IOException
java.io.IOException
protected void updateNodeStatus(cascading.stats.FlowNodeStats flowNodeStats)
updateNodeStatus
in class cascading.flow.planner.FlowStepJob<JobConf>
public boolean isSuccessful()
isSuccessful
in class cascading.flow.planner.FlowStepJob<JobConf>
protected boolean internalNonBlockingIsSuccessful() throws java.io.IOException
internalNonBlockingIsSuccessful
in class cascading.flow.planner.FlowStepJob<JobConf>
java.io.IOException
protected boolean isRemoteExecution()
isRemoteExecution
in class cascading.flow.planner.FlowStepJob<JobConf>
protected java.lang.Throwable getThrowable()
getThrowable
in class cascading.flow.planner.FlowStepJob<JobConf>
protected java.lang.String internalJobId()
internalJobId
in class cascading.flow.planner.FlowStepJob<JobConf>
protected boolean internalNonBlockingIsComplete() throws java.io.IOException
internalNonBlockingIsComplete
in class cascading.flow.planner.FlowStepJob<JobConf>
java.io.IOException
protected void dumpDebugInfo()
dumpDebugInfo
in class cascading.flow.planner.FlowStepJob<JobConf>
protected boolean internalIsStartedRunning()
internalIsStartedRunning
in class cascading.flow.planner.FlowStepJob<JobConf>
public static void reportLocalError(java.lang.Throwable throwable)
throwable
- the throwable to be reported.Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.