public class PartitionedStepController extends BaseStepController
Modifier and Type | Field and Description |
---|---|
protected List<javax.batch.api.listener.StepListener> |
stepListeners |
analyzerStatusQueue, jobExecutionImpl, jobInstance, kernelService, persistenceManagerService, restartAfterCompletion, rootJobExecutionId, step, stepContext, stepName, stepStatus, transactionManager
Modifier | Constructor and Description |
---|---|
protected |
PartitionedStepController(RuntimeJobExecution jobExecutionImpl,
Step step,
StepContextImpl stepContext,
long rootJobExecutionId,
ServicesManager servicesManager) |
Modifier and Type | Method and Description |
---|---|
protected void |
invokeCoreStep() |
protected void |
invokePostStepArtifacts() |
protected void |
invokePreStepArtifacts() |
protected void |
sendStatusFromPartitionToAnalyzerIfPresent() |
protected void |
setupStepArtifacts() |
void |
stop() |
execute, getLastRunStepExecutions, isRestartExecution, markJobAndStepFailed, persistExitStatusAndEndTimestamp, persistUserData, resolveUserData, setParentStepContext, setStepContext, shouldStepBeExecuted, statusStarting, storeUserData, toString, updateBatchStatus
protected List<javax.batch.api.listener.StepListener> stepListeners
protected PartitionedStepController(RuntimeJobExecution jobExecutionImpl, Step step, StepContextImpl stepContext, long rootJobExecutionId, ServicesManager servicesManager)
public void stop()
protected void invokeCoreStep() throws javax.batch.operations.JobRestartException, javax.batch.operations.JobStartException, javax.batch.operations.JobExecutionAlreadyCompleteException, javax.batch.operations.JobExecutionNotMostRecentException
invokeCoreStep
in class BaseStepController
javax.batch.operations.JobRestartException
javax.batch.operations.JobStartException
javax.batch.operations.JobExecutionAlreadyCompleteException
javax.batch.operations.JobExecutionNotMostRecentException
protected void setupStepArtifacts()
setupStepArtifacts
in class BaseStepController
protected void invokePreStepArtifacts()
invokePreStepArtifacts
in class BaseStepController
protected void invokePostStepArtifacts()
invokePostStepArtifacts
in class BaseStepController
protected void sendStatusFromPartitionToAnalyzerIfPresent()
sendStatusFromPartitionToAnalyzerIfPresent
in class BaseStepController
Copyright © 2017 The Apache Software Foundation. All rights reserved.