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 List<FlowStepJob<Config>> |
predecessors
Field predecessors
|
protected long |
statsStoreInterval
Field recordStatsInterval
|
protected String |
stepName
Field stepName
|
protected 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() |
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 Throwable |
getThrowable() |
protected abstract void |
internalBlockOnStop() |
protected void |
internalCleanup() |
protected abstract boolean |
internalIsStartedRunning() |
protected abstract String |
internalJobId() |
protected abstract boolean |
internalNonBlockingIsComplete() |
protected abstract boolean |
internalNonBlockingIsSuccessful() |
protected abstract void |
internalNonBlockingStart() |
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(List<FlowStepJob<Config>> predecessors) |
protected void |
sleepForPollingInterval() |
protected void |
start() |
void |
stop() |
protected abstract void |
updateNodeStatus(FlowNodeStats flowNodeStats) |
protected final Config jobConfiguration
protected long pollingInterval
protected long statsStoreInterval
protected long blockForCompletedChildDetailDuration
protected List<FlowStepJob<Config>> predecessors
protected final BaseFlowStep<Config> flowStep
protected FlowStepStats flowStepStats
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 IOException
IOException
public void setPredecessors(List<FlowStepJob<Config>> predecessors)
protected void start()
protected boolean isSkipFlowStep() throws IOException
IOException
protected void blockOnJob() throws IOException
IOException
protected void finalizeNodeSliceCapture()
protected abstract boolean isRemoteExecution()
protected abstract String internalJobId()
protected abstract boolean internalNonBlockingIsSuccessful() throws IOException
IOException
protected abstract Throwable getThrowable()
protected abstract void internalNonBlockingStart() throws IOException
IOException
protected void blockTillCompleteOrStopped() throws IOException
IOException
protected abstract void updateNodeStatus(FlowNodeStats flowNodeStats)
protected abstract boolean internalNonBlockingIsComplete() throws IOException
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 Concurrent, Inc. All Rights Reserved.