public abstract class FlowStepJob<Config> extends java.lang.Object implements java.util.concurrent.Callable<java.lang.Throwable>
Modifier and Type | Field and Description |
---|---|
protected long |
blockForCompletedChildDetailDuration
Field waitTillCompletedChildStatsDuration
|
protected BaseFlowStep<Config> |
flowStep
Field flowStep
|
protected FlowStepStats |
flowStepStats
Field stepStats
|
protected Config |
jobConfiguration
Field jobConfiguration
|
protected long |
pollingInterval
Field pollingInterval
|
protected java.util.List<FlowStepJob<Config>> |
predecessors
Field predecessors
|
protected long |
statsStoreInterval
Field recordStatsInterval
|
protected java.lang.String |
stepName
Field stepName
|
protected java.lang.Throwable |
throwable
Field throwable
|
Constructor and Description |
---|
FlowStepJob(ClientState clientState,
Config jobConfiguration,
BaseFlowStep<Config> flowStep,
long pollingInterval,
long statsStoreInterval,
long blockForCompletedChildDetailDuration) |
Modifier and Type | Method and Description |
---|---|
protected void |
blockOnJob() |
protected void |
blockOnPredecessors() |
protected void |
blockTillCompleteOrStopped() |
java.lang.Throwable |
call() |
protected abstract FlowStepStats |
createStepStats(ClientState clientState) |
protected abstract void |
dumpDebugInfo() |
protected void |
finalizeNodeSliceCapture() |
Config |
getConfig() |
FlowStepStats |
getStepStats()
Method getStepStats returns the stepStats of this FlowStepJob object.
|
protected abstract java.lang.Throwable |
getThrowable() |
protected abstract void |
internalBlockOnStop() |
protected void |
internalCleanup() |
protected abstract boolean |
internalIsStartedRunning() |
protected abstract java.lang.String |
internalJobId() |
protected abstract boolean |
internalNonBlockingIsComplete() |
protected abstract boolean |
internalNonBlockingIsSuccessful() |
protected abstract void |
internalNonBlockingStart() |
boolean |
isCallableStarted() |
protected abstract boolean |
isRemoteExecution() |
protected boolean |
isSkipFlowStep() |
boolean |
isStarted()
Method isStarted returns true if this underlying job has started running
|
boolean |
isSuccessful()
Method isSuccessful returns true if this step completed successfully or was skipped.
|
void |
setPredecessors(java.util.List<FlowStepJob<Config>> predecessors) |
protected void |
sleepForPollingInterval() |
protected void |
start() |
void |
stop() |
protected abstract void |
updateNodeStatus(FlowNodeStats flowNodeStats) |
protected final java.lang.String stepName
protected final Config jobConfiguration
protected long pollingInterval
protected long statsStoreInterval
protected long blockForCompletedChildDetailDuration
protected java.util.List<FlowStepJob<Config>> predecessors
protected final BaseFlowStep<Config> flowStep
protected FlowStepStats flowStepStats
protected java.lang.Throwable throwable
public FlowStepJob(ClientState clientState, Config jobConfiguration, BaseFlowStep<Config> flowStep, long pollingInterval, long statsStoreInterval, long blockForCompletedChildDetailDuration)
protected abstract FlowStepStats createStepStats(ClientState clientState)
public void stop()
protected abstract void internalBlockOnStop() throws java.io.IOException
java.io.IOException
public void setPredecessors(java.util.List<FlowStepJob<Config>> predecessors)
public java.lang.Throwable call()
call
in interface java.util.concurrent.Callable<java.lang.Throwable>
public boolean isCallableStarted()
protected void start()
protected boolean isSkipFlowStep() throws java.io.IOException
java.io.IOException
protected void blockOnJob() throws java.io.IOException
java.io.IOException
protected void finalizeNodeSliceCapture()
protected abstract boolean isRemoteExecution()
protected abstract java.lang.String internalJobId()
protected abstract boolean internalNonBlockingIsSuccessful() throws java.io.IOException
java.io.IOException
protected abstract java.lang.Throwable getThrowable()
protected abstract void internalNonBlockingStart() throws java.io.IOException
java.io.IOException
protected void blockTillCompleteOrStopped() throws java.io.IOException
java.io.IOException
protected abstract void updateNodeStatus(FlowNodeStats flowNodeStats)
protected abstract boolean internalNonBlockingIsComplete() throws java.io.IOException
java.io.IOException
protected void sleepForPollingInterval()
protected void blockOnPredecessors()
protected abstract void dumpDebugInfo()
public boolean isSuccessful()
public boolean isStarted()
protected abstract boolean internalIsStartedRunning()
protected void internalCleanup()
public FlowStepStats getStepStats()
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.