public abstract class BaseStepController extends Object implements ExecutionElementController
Modifier and Type | Field and Description |
---|---|
protected BlockingQueue<PartitionDataWrapper> |
analyzerStatusQueue |
protected RuntimeJobExecution |
jobExecutionImpl |
protected javax.batch.runtime.JobInstance |
jobInstance |
protected BatchKernelService |
kernelService |
protected PersistenceManagerService |
persistenceManagerService |
protected boolean |
restartAfterCompletion |
protected long |
rootJobExecutionId |
protected Step |
step |
protected StepContextImpl |
stepContext |
protected String |
stepName |
protected StepStatus |
stepStatus |
protected TransactionManagerAdapter |
transactionManager |
Modifier | Constructor and Description |
---|---|
protected |
BaseStepController(RuntimeJobExecution jobExecution,
Step step,
StepContextImpl stepContext,
long rootJobExecutionId,
BlockingQueue<PartitionDataWrapper> analyzerStatusQueue,
ServicesManager servicesManager) |
protected |
BaseStepController(RuntimeJobExecution jobExecution,
Step step,
StepContextImpl stepContext,
long rootJobExecutionId,
ServicesManager servicesManager) |
Modifier and Type | Method and Description |
---|---|
ExecutionStatus |
execute() |
List<Long> |
getLastRunStepExecutions() |
protected abstract void |
invokeCoreStep() |
protected abstract void |
invokePostStepArtifacts() |
protected abstract void |
invokePreStepArtifacts() |
protected boolean |
isRestartExecution() |
protected void |
markJobAndStepFailed() |
protected void |
persistExitStatusAndEndTimestamp() |
protected void |
persistUserData() |
protected PersistentDataWrapper |
resolveUserData() |
protected abstract void |
sendStatusFromPartitionToAnalyzerIfPresent() |
void |
setParentStepContext(StepContextImpl parentStepContext) |
void |
setStepContext(StepContextImpl stepContext) |
protected abstract void |
setupStepArtifacts() |
protected boolean |
shouldStepBeExecuted() |
protected void |
statusStarting() |
protected void |
storeUserData(PersistentDataWrapper userData) |
String |
toString() |
protected void |
updateBatchStatus(javax.batch.runtime.BatchStatus updatedBatchStatus) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
stop
protected RuntimeJobExecution jobExecutionImpl
protected javax.batch.runtime.JobInstance jobInstance
protected StepContextImpl stepContext
protected Step step
protected String stepName
protected StepStatus stepStatus
protected BlockingQueue<PartitionDataWrapper> analyzerStatusQueue
protected long rootJobExecutionId
protected boolean restartAfterCompletion
protected final BatchKernelService kernelService
protected final PersistenceManagerService persistenceManagerService
protected TransactionManagerAdapter transactionManager
protected BaseStepController(RuntimeJobExecution jobExecution, Step step, StepContextImpl stepContext, long rootJobExecutionId, ServicesManager servicesManager)
protected BaseStepController(RuntimeJobExecution jobExecution, Step step, StepContextImpl stepContext, long rootJobExecutionId, BlockingQueue<PartitionDataWrapper> analyzerStatusQueue, ServicesManager servicesManager)
protected abstract void invokeCoreStep() throws javax.batch.operations.JobRestartException, javax.batch.operations.JobStartException, javax.batch.operations.JobExecutionAlreadyCompleteException, javax.batch.operations.JobExecutionNotMostRecentException
javax.batch.operations.JobRestartException
javax.batch.operations.JobStartException
javax.batch.operations.JobExecutionAlreadyCompleteException
javax.batch.operations.JobExecutionNotMostRecentException
protected abstract void setupStepArtifacts()
protected abstract void invokePreStepArtifacts()
protected abstract void invokePostStepArtifacts()
protected abstract void sendStatusFromPartitionToAnalyzerIfPresent()
public ExecutionStatus execute()
execute
in interface ExecutionElementController
protected void markJobAndStepFailed()
protected void updateBatchStatus(javax.batch.runtime.BatchStatus updatedBatchStatus)
protected boolean shouldStepBeExecuted()
protected boolean isRestartExecution()
protected void statusStarting()
protected void persistUserData()
protected PersistentDataWrapper resolveUserData()
protected void storeUserData(PersistentDataWrapper userData)
protected void persistExitStatusAndEndTimestamp()
public void setStepContext(StepContextImpl stepContext)
public List<Long> getLastRunStepExecutions()
getLastRunStepExecutions
in interface Controller
public void setParentStepContext(StepContextImpl parentStepContext)
Copyright © 2017 The Apache Software Foundation. All rights reserved.