public abstract class JobThreadRootController extends Object implements ThreadRootController
Modifier and Type | Field and Description |
---|---|
protected JobContextImpl |
jobContext |
protected RuntimeJobExecution |
jobExecution |
protected long |
jobInstanceId |
protected ModelNavigator<JSLJob> |
jobNavigator |
protected JobStatusManagerService |
jobStatusService |
protected ServicesManager |
manager |
protected StepContextImpl |
parentStepContext |
protected PersistenceManagerService |
persistenceService |
protected long |
rootJobExecutionId |
Constructor and Description |
---|
JobThreadRootController(RuntimeJobExecution jobExecution,
BlockingQueue<PartitionDataWrapper> analyzerQueue,
ServicesManager servicesManager) |
JobThreadRootController(RuntimeJobExecution jobExecution,
long rootJobExecutionId,
ServicesManager servicesManager) |
Modifier and Type | Method and Description |
---|---|
protected void |
batchStatusFailedFromException() |
protected void |
batchStatusStopping() |
protected void |
endOfJob() |
List<Long> |
getLastRunStepExecutions() |
protected void |
jobListenersBeforeJob() |
protected void |
jslStop() |
protected void |
markJobStarted() |
ExecutionStatus |
originateExecutionOnThread() |
void |
setParentStepContext(StepContextImpl parentStepContext) |
void |
stop() |
protected void |
updateJobBatchStatus(javax.batch.runtime.BatchStatus batchStatus) |
protected final RuntimeJobExecution jobExecution
protected final JobContextImpl jobContext
protected final long rootJobExecutionId
protected final long jobInstanceId
protected final ModelNavigator<JSLJob> jobNavigator
protected final JobStatusManagerService jobStatusService
protected final PersistenceManagerService persistenceService
protected final ServicesManager manager
protected StepContextImpl parentStepContext
public JobThreadRootController(RuntimeJobExecution jobExecution, long rootJobExecutionId, ServicesManager servicesManager)
public JobThreadRootController(RuntimeJobExecution jobExecution, BlockingQueue<PartitionDataWrapper> analyzerQueue, ServicesManager servicesManager)
public ExecutionStatus originateExecutionOnThread()
originateExecutionOnThread
in interface ThreadRootController
protected void jslStop()
protected void markJobStarted()
protected void endOfJob()
protected void updateJobBatchStatus(javax.batch.runtime.BatchStatus batchStatus)
protected void batchStatusStopping()
public void stop()
stop
in interface Controller
protected void jobListenersBeforeJob()
protected void batchStatusFailedFromException()
public List<Long> getLastRunStepExecutions()
getLastRunStepExecutions
in interface Controller
public void setParentStepContext(StepContextImpl parentStepContext)
setParentStepContext
in interface ThreadRootController
Copyright © 2017 The Apache Software Foundation. All rights reserved.