Modifier and Type | Method and Description |
---|---|
StepExecution |
JobExecution.createStepExecution(String stepName)
Register a step execution with the current job execution.
|
Modifier and Type | Method and Description |
---|---|
Collection<StepExecution> |
JobExecution.getStepExecutions()
Accessor for the step executions.
|
Modifier and Type | Method and Description |
---|---|
ExitStatus |
StepExecutionListener.afterStep(StepExecution stepExecution)
Give a listener a chance to modify the exit status from a step.
|
void |
StepExecutionListener.beforeStep(StepExecution stepExecution)
Initialize the state of the listener with the
StepExecution from
the current scope. |
void |
Step.execute(StepExecution stepExecution)
Process the step and assign progress and status meta information to the
StepExecution provided. |
Modifier and Type | Method and Description |
---|---|
void |
JobExecution.addStepExecutions(List<StepExecution> stepExecutions)
Add some step executions.
|
Constructor and Description |
---|
StepContribution(StepExecution execution) |
Modifier and Type | Method and Description |
---|---|
StepExecution |
JobExplorer.getStepExecution(Long jobExecutionId,
Long stepExecutionId)
Retrieve a
StepExecution by its id and parent
JobExecution id. |
Modifier and Type | Method and Description |
---|---|
StepExecution |
SimpleJobExplorer.getStepExecution(Long jobExecutionId,
Long executionId) |
Modifier and Type | Method and Description |
---|---|
StepExecution |
StepHandler.handleStep(Step step,
JobExecution jobExecution)
Handle a step and return the execution for it.
|
protected StepExecution |
AbstractJob.handleStep(Step step,
JobExecution execution)
Convenience method for subclasses to delegate the handling of a specific
step in the context of the current
JobExecution . |
StepExecution |
SimpleStepHandler.handleStep(Step step,
JobExecution execution) |
Modifier and Type | Method and Description |
---|---|
StepExecution |
FlowExecutor.getStepExecution() |
StepExecution |
JobFlowExecutor.getStepExecution() |
Modifier and Type | Method and Description |
---|---|
FlowExecutionStatus |
JobExecutionDecider.decide(JobExecution jobExecution,
StepExecution stepExecution)
Strategy for branching an execution based on the state of an ongoing
JobExecution . |
protected void |
FlowStep.doExecute(StepExecution stepExecution)
Delegate to the flow provided for the execution of the step.
|
Modifier and Type | Method and Description |
---|---|
ExitStatus |
StepListenerSupport.afterStep(StepExecution stepExecution) |
ExitStatus |
StepExecutionListenerSupport.afterStep(StepExecution stepExecution) |
ExitStatus |
ExecutionContextPromotionListener.afterStep(StepExecution stepExecution) |
ExitStatus |
MulticasterBatchListener.afterStep(StepExecution stepExecution) |
ExitStatus |
CompositeStepExecutionListener.afterStep(StepExecution stepExecution)
Call the registered listeners in reverse order, respecting and
prioritising those that implement
Ordered . |
void |
StepListenerSupport.beforeStep(StepExecution stepExecution) |
void |
StepExecutionListenerSupport.beforeStep(StepExecution stepExecution) |
void |
JobParameterExecutionContextCopyListener.beforeStep(StepExecution stepExecution)
|
void |
MulticasterBatchListener.beforeStep(StepExecution stepExecution) |
void |
CompositeStepExecutionListener.beforeStep(StepExecution stepExecution)
Call the registered listeners in order, respecting and prioritising those
that implement
Ordered . |
Modifier and Type | Method and Description |
---|---|
Collection<StepExecution> |
PartitionHandler.handle(StepExecutionSplitter stepSplitter,
StepExecution stepExecution)
Main entry point for
PartitionHandler interface. |
Set<StepExecution> |
StepExecutionSplitter.split(StepExecution stepExecution,
int gridSize)
Partition the provided
StepExecution into a set of parallel
executable instances with the same parent JobExecution . |
Modifier and Type | Method and Description |
---|---|
Collection<StepExecution> |
PartitionHandler.handle(StepExecutionSplitter stepSplitter,
StepExecution stepExecution)
Main entry point for
PartitionHandler interface. |
Set<StepExecution> |
StepExecutionSplitter.split(StepExecution stepExecution,
int gridSize)
Partition the provided
StepExecution into a set of parallel
executable instances with the same parent JobExecution . |
Modifier and Type | Method and Description |
---|---|
Collection<StepExecution> |
TaskExecutorPartitionHandler.handle(StepExecutionSplitter stepExecutionSplitter,
StepExecution masterStepExecution) |
Set<StepExecution> |
SimpleStepExecutionSplitter.split(StepExecution stepExecution,
int gridSize) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultStepExecutionAggregator.aggregate(StepExecution result,
Collection<StepExecution> executions)
Aggregates the input executions into the result
StepExecution . |
void |
RemoteStepExecutionAggregator.aggregate(StepExecution result,
Collection<StepExecution> executions)
Aggregates the input executions into the result
StepExecution
delegating to the delegate aggregator once the input has been refreshed
from the JobExplorer . |
void |
StepExecutionAggregator.aggregate(StepExecution result,
Collection<StepExecution> executions)
Take the inputs and aggregate, putting the aggregates into the result.
|
protected void |
PartitionStep.doExecute(StepExecution stepExecution)
Delegate execution to the
PartitionHandler provided. |
Collection<StepExecution> |
TaskExecutorPartitionHandler.handle(StepExecutionSplitter stepExecutionSplitter,
StepExecution masterStepExecution) |
Set<StepExecution> |
SimpleStepExecutionSplitter.split(StepExecution stepExecution,
int gridSize) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultStepExecutionAggregator.aggregate(StepExecution result,
Collection<StepExecution> executions)
Aggregates the input executions into the result
StepExecution . |
void |
RemoteStepExecutionAggregator.aggregate(StepExecution result,
Collection<StepExecution> executions)
Aggregates the input executions into the result
StepExecution
delegating to the delegate aggregator once the input has been refreshed
from the JobExplorer . |
void |
StepExecutionAggregator.aggregate(StepExecution result,
Collection<StepExecution> executions)
Take the inputs and aggregate, putting the aggregates into the result.
|
Modifier and Type | Method and Description |
---|---|
StepExecution |
JobRepository.getLastStepExecution(JobInstance jobInstance,
String stepName) |
Modifier and Type | Method and Description |
---|---|
void |
JobRepository.add(StepExecution stepExecution)
Save the
StepExecution and its ExecutionContext . |
void |
JobRepository.update(StepExecution stepExecution)
Update the
StepExecution (but not its ExecutionContext ). |
void |
JobRepository.updateExecutionContext(StepExecution stepExecution)
Persist the updated
ExecutionContext s of the given
StepExecution . |
Modifier and Type | Method and Description |
---|---|
StepExecution |
StepExecutionDao.getStepExecution(JobExecution jobExecution,
Long stepExecutionId)
Retrieve a
StepExecution from its id. |
StepExecution |
JdbcStepExecutionDao.getStepExecution(JobExecution jobExecution,
Long stepExecutionId) |
StepExecution |
MapStepExecutionDao.getStepExecution(JobExecution jobExecution,
Long stepExecutionId) |
Modifier and Type | Method and Description |
---|---|
ExecutionContext |
MapExecutionContextDao.getExecutionContext(StepExecution stepExecution) |
ExecutionContext |
JdbcExecutionContextDao.getExecutionContext(StepExecution stepExecution) |
ExecutionContext |
ExecutionContextDao.getExecutionContext(StepExecution stepExecution) |
void |
MapExecutionContextDao.saveExecutionContext(StepExecution stepExecution) |
void |
JdbcExecutionContextDao.saveExecutionContext(StepExecution stepExecution) |
void |
ExecutionContextDao.saveExecutionContext(StepExecution stepExecution)
Persist the execution context associated with the given stepExecution,
persistent entry for the context should not exist yet.
|
void |
StepExecutionDao.saveStepExecution(StepExecution stepExecution)
Save the given StepExecution.
|
void |
JdbcStepExecutionDao.saveStepExecution(StepExecution stepExecution)
Save a StepExecution.
|
void |
MapStepExecutionDao.saveStepExecution(StepExecution stepExecution) |
void |
MapExecutionContextDao.updateExecutionContext(StepExecution stepExecution) |
void |
JdbcExecutionContextDao.updateExecutionContext(StepExecution stepExecution) |
void |
ExecutionContextDao.updateExecutionContext(StepExecution stepExecution)
Persist the updates of execution context associated with the given
stepExecution.
|
void |
StepExecutionDao.updateStepExecution(StepExecution stepExecution)
Update the given StepExecution
Preconditions: Id must not be null.
|
void |
JdbcStepExecutionDao.updateStepExecution(StepExecution stepExecution) |
void |
MapStepExecutionDao.updateStepExecution(StepExecution stepExecution) |
Modifier and Type | Method and Description |
---|---|
StepExecution |
SimpleJobRepository.getLastStepExecution(JobInstance jobInstance,
String stepName) |
Modifier and Type | Method and Description |
---|---|
void |
SimpleJobRepository.add(StepExecution stepExecution) |
void |
SimpleJobRepository.update(StepExecution stepExecution) |
void |
SimpleJobRepository.updateExecutionContext(StepExecution stepExecution) |
Modifier and Type | Method and Description |
---|---|
void |
StepExecutionSimpleCompletionPolicy.beforeStep(StepExecution stepExecution)
Set up a
SimpleCompletionPolicy with a commit interval taken from
the JobParameters . |
Modifier and Type | Method and Description |
---|---|
StepExecution |
StepContext.getStepExecution()
The current
StepExecution that is active in this context. |
Modifier and Type | Method and Description |
---|---|
void |
StepScopeManager.execute(Step step,
StepExecution stepExecution) |
static StepContext |
StepSynchronizationManager.register(StepExecution stepExecution)
Register a context with the current thread - always put a matching
StepSynchronizationManager.close() call in a finally block to ensure that the correct
context is available in the enclosing block. |
Constructor and Description |
---|
StepContext(StepExecution stepExecution)
Create a new instance of
StepContext for this
StepExecution . |
StepContextRepeatCallback(StepExecution stepExecution) |
Modifier and Type | Method and Description |
---|---|
ExitStatus |
NoWorkFoundStepExecutionListener.afterStep(StepExecution stepExecution) |
void |
ThreadStepInterruptionPolicy.checkInterrupted(StepExecution stepExecution)
Returns if the current job lifecycle has been interrupted by checking if
the current thread is interrupted.
|
void |
StepInterruptionPolicy.checkInterrupted(StepExecution stepExecution)
Has the job been interrupted? If so then throw a
JobInterruptedException . |
protected abstract void |
AbstractStep.doExecute(StepExecution stepExecution)
Extension point for subclasses to execute business logic.
|
void |
AbstractStep.execute(StepExecution stepExecution)
Template method for step execution logic - calls abstract methods for
resource initialization (
AbstractStep.open(ExecutionContext) ), execution
logic (AbstractStep.doExecute(StepExecution) ) and resource closing (
AbstractStep.close(ExecutionContext) ). |
Modifier and Type | Method and Description |
---|---|
protected void |
JobStep.doExecute(StepExecution stepExecution)
Execute the job provided by delegating to the
JobLauncher to
prevent duplicate executions. |
JobParameters |
DefaultJobParametersExtractor.getJobParameters(Job job,
StepExecution stepExecution) |
JobParameters |
JobParametersExtractor.getJobParameters(Job job,
StepExecution stepExecution)
Extract job parameters from the step execution, for example from the
execution context or other properties.
|
Modifier and Type | Method and Description |
---|---|
void |
SystemCommandTasklet.beforeStep(StepExecution stepExecution)
Get a reference to
StepExecution for interrupt checks during
system command execution. |
protected void |
TaskletStep.doExecute(StepExecution stepExecution)
Process the step and update its context so that progress can be monitored
by the caller.
|
Modifier and Type | Method and Description |
---|---|
static StepExecution |
MetaDataInstanceFactory.createStepExecution()
Create a
StepExecution with default parameters. |
static StepExecution |
MetaDataInstanceFactory.createStepExecution(ExecutionContext executionContext)
Create a
StepExecution and all its parent entities with default
values, but using the ExecutionContext provided. |
static StepExecution |
MetaDataInstanceFactory.createStepExecution(JobExecution jobExecution,
String stepName,
Long executionId)
Create a
StepExecution with the parameters provided. |
static StepExecution |
MetaDataInstanceFactory.createStepExecution(JobParameters jobParameters)
Create a
StepExecution and all its parent entities with default
values, but using the JobParameters provided. |
static StepExecution |
MetaDataInstanceFactory.createStepExecution(JobParameters jobParameters,
ExecutionContext executionContext)
Create a
StepExecution and all its parent entities with default
values, but using the ExecutionContext and JobParameters
provided. |
static StepExecution |
MetaDataInstanceFactory.createStepExecution(String stepName,
Long executionId)
Create a
StepExecution with the parameters provided. |
Modifier and Type | Method and Description |
---|---|
static <T> T |
StepScopeTestUtils.doInStepScope(StepExecution stepExecution,
Callable<T> callable) |
static <T> T |
ExecutionContextTestUtils.getValueFromStep(StepExecution stepExecution,
String key) |
Copyright © 2013 SpringSource. All rights reserved.