public abstract class SingleThreadedStepController extends BaseStepController implements Controller
When a non-partitioned step is run this controller will be used as well (and there will be no separate main thread with controller).
Modifier and Type | Field and Description |
---|---|
protected javax.batch.api.partition.PartitionCollector |
collectorProxy |
analyzerStatusQueue, jobExecutionImpl, jobInstance, kernelService, persistenceManagerService, restartAfterCompletion, rootJobExecutionId, step, stepContext, stepName, stepStatus, transactionManager
Modifier | Constructor and Description |
---|---|
protected |
SingleThreadedStepController(RuntimeJobExecution jobExecutionImpl,
Step step,
StepContextImpl stepContext,
long rootJobExecutionId,
BlockingQueue<PartitionDataWrapper> analyzerStatusQueue,
ServicesManager servicesManager) |
Modifier and Type | Method and Description |
---|---|
protected void |
invokeCollectorIfPresent() |
protected void |
invokePostStepArtifacts() |
protected void |
invokePreStepArtifacts() |
protected void |
sendCollectorDataToAnalyzerIfPresent(Serializable data) |
protected void |
sendStatusFromPartitionToAnalyzerIfPresent() |
protected void |
setupStepArtifacts() |
execute, getLastRunStepExecutions, invokeCoreStep, isRestartExecution, markJobAndStepFailed, persistExitStatusAndEndTimestamp, persistUserData, resolveUserData, setParentStepContext, setStepContext, shouldStepBeExecuted, statusStarting, storeUserData, toString, updateBatchStatus
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getLastRunStepExecutions, stop
protected SingleThreadedStepController(RuntimeJobExecution jobExecutionImpl, Step step, StepContextImpl stepContext, long rootJobExecutionId, BlockingQueue<PartitionDataWrapper> analyzerStatusQueue, ServicesManager servicesManager)
protected void setupStepArtifacts()
setupStepArtifacts
in class BaseStepController
protected void invokePreStepArtifacts()
invokePreStepArtifacts
in class BaseStepController
protected void invokePostStepArtifacts()
invokePostStepArtifacts
in class BaseStepController
protected void invokeCollectorIfPresent()
protected void sendCollectorDataToAnalyzerIfPresent(Serializable data)
protected void sendStatusFromPartitionToAnalyzerIfPresent()
sendStatusFromPartitionToAnalyzerIfPresent
in class BaseStepController
Copyright © 2017 The Apache Software Foundation. All rights reserved.