Class JobThreadRootController
- java.lang.Object
-
- org.apache.batchee.container.impl.controller.JobThreadRootController
-
- All Implemented Interfaces:
Controller,ThreadRootController
- Direct Known Subclasses:
FlowInSplitThreadRootController,JobController,PartitionThreadRootController
public abstract class JobThreadRootController extends Object implements ThreadRootController
-
-
Field Summary
Fields Modifier and Type Field Description protected JobContextImpljobContextprotected RuntimeJobExecutionjobExecutionprotected longjobInstanceIdprotected ModelNavigator<JSLJob>jobNavigatorprotected JobStatusManagerServicejobStatusServiceprotected ServicesManagermanagerprotected StepContextImplparentStepContextprotected PersistenceManagerServicepersistenceServiceprotected longrootJobExecutionId
-
Constructor Summary
Constructors Constructor Description JobThreadRootController(RuntimeJobExecution jobExecution, long rootJobExecutionId, ServicesManager servicesManager)JobThreadRootController(RuntimeJobExecution jobExecution, BlockingQueue<PartitionDataWrapper> analyzerQueue, ServicesManager servicesManager)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected voidbatchStatusFailedFromException()protected voidbatchStatusStopping()protected voidendOfJob()List<Long>getLastRunStepExecutions()protected voidjobListenersBeforeJob()protected voidjslStop()protected voidmarkJobStarted()ExecutionStatusoriginateExecutionOnThread()voidsetParentStepContext(StepContextImpl parentStepContext)voidstop()protected voidupdateJobBatchStatus(javax.batch.runtime.BatchStatus batchStatus)
-
-
-
Field Detail
-
jobExecution
protected final RuntimeJobExecution jobExecution
-
jobContext
protected final JobContextImpl jobContext
-
rootJobExecutionId
protected final long rootJobExecutionId
-
jobInstanceId
protected final long jobInstanceId
-
jobNavigator
protected final ModelNavigator<JSLJob> jobNavigator
-
jobStatusService
protected final JobStatusManagerService jobStatusService
-
persistenceService
protected final PersistenceManagerService persistenceService
-
manager
protected final ServicesManager manager
-
parentStepContext
protected StepContextImpl parentStepContext
-
-
Constructor Detail
-
JobThreadRootController
public JobThreadRootController(RuntimeJobExecution jobExecution, long rootJobExecutionId, ServicesManager servicesManager)
-
JobThreadRootController
public JobThreadRootController(RuntimeJobExecution jobExecution, BlockingQueue<PartitionDataWrapper> analyzerQueue, ServicesManager servicesManager)
-
-
Method Detail
-
originateExecutionOnThread
public ExecutionStatus originateExecutionOnThread()
- Specified by:
originateExecutionOnThreadin interfaceThreadRootController
-
jslStop
protected void jslStop()
-
markJobStarted
protected void markJobStarted()
-
endOfJob
protected void endOfJob()
-
updateJobBatchStatus
protected void updateJobBatchStatus(javax.batch.runtime.BatchStatus batchStatus)
-
batchStatusStopping
protected void batchStatusStopping()
-
stop
public void stop()
- Specified by:
stopin interfaceController
-
jobListenersBeforeJob
protected void jobListenersBeforeJob()
-
batchStatusFailedFromException
protected void batchStatusFailedFromException()
-
getLastRunStepExecutions
public List<Long> getLastRunStepExecutions()
- Specified by:
getLastRunStepExecutionsin interfaceController
-
setParentStepContext
public void setParentStepContext(StepContextImpl parentStepContext)
- Specified by:
setParentStepContextin interfaceThreadRootController
-
-