Class SingleThreadedStepController
- java.lang.Object
-
- org.apache.batchee.container.impl.controller.BaseStepController
-
- org.apache.batchee.container.impl.controller.SingleThreadedStepController
-
- All Implemented Interfaces:
Controller,ExecutionElementController
- Direct Known Subclasses:
BatchletStepController,ChunkStepController
public abstract class SingleThreadedStepController extends BaseStepController implements Controller
When a partitioned step is run, this controller will only be used for the partition threads, NOT the top-level main thread that the step executes upon.When a non-partitioned step is run this controller will be used as well (and there will be no separate main thread with controller).
-
-
Field Summary
Fields Modifier and Type Field Description protected javax.batch.api.partition.PartitionCollectorcollectorProxy-
Fields inherited from class org.apache.batchee.container.impl.controller.BaseStepController
analyzerStatusQueue, jobExecutionImpl, jobInstance, kernelService, persistenceManagerService, restartAfterCompletion, rootJobExecutionId, step, stepContext, stepName, stepStatus, transactionManager
-
-
Constructor Summary
Constructors Modifier Constructor Description protectedSingleThreadedStepController(RuntimeJobExecution jobExecutionImpl, Step step, StepContextImpl stepContext, long rootJobExecutionId, BlockingQueue<PartitionDataWrapper> analyzerStatusQueue, ServicesManager servicesManager)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected voidinvokeCollectorIfPresent()protected voidinvokePostStepArtifacts()protected voidinvokePreStepArtifacts()protected voidsendCollectorDataToAnalyzerIfPresent(Serializable data)protected voidsendStatusFromPartitionToAnalyzerIfPresent()protected voidsetupStepArtifacts()-
Methods inherited from class org.apache.batchee.container.impl.controller.BaseStepController
execute, getLastRunStepExecutions, invokeCoreStep, isRestartExecution, markJobAndStepFailed, persistExitStatusAndEndTimestamp, persistUserData, resolveUserData, setParentStepContext, setStepContext, shouldStepBeExecuted, statusStarting, storeUserData, toString, updateBatchStatus
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.apache.batchee.container.Controller
getLastRunStepExecutions, stop
-
-
-
-
Constructor Detail
-
SingleThreadedStepController
protected SingleThreadedStepController(RuntimeJobExecution jobExecutionImpl, Step step, StepContextImpl stepContext, long rootJobExecutionId, BlockingQueue<PartitionDataWrapper> analyzerStatusQueue, ServicesManager servicesManager)
-
-
Method Detail
-
setupStepArtifacts
protected void setupStepArtifacts()
- Specified by:
setupStepArtifactsin classBaseStepController
-
invokePreStepArtifacts
protected void invokePreStepArtifacts()
- Specified by:
invokePreStepArtifactsin classBaseStepController
-
invokePostStepArtifacts
protected void invokePostStepArtifacts()
- Specified by:
invokePostStepArtifactsin classBaseStepController
-
invokeCollectorIfPresent
protected void invokeCollectorIfPresent()
-
sendCollectorDataToAnalyzerIfPresent
protected void sendCollectorDataToAnalyzerIfPresent(Serializable data)
-
sendStatusFromPartitionToAnalyzerIfPresent
protected void sendStatusFromPartitionToAnalyzerIfPresent()
- Specified by:
sendStatusFromPartitionToAnalyzerIfPresentin classBaseStepController
-
-