Package | Description |
---|---|
org.springframework.batch.core |
Core domain context for Spring Batch covering jobs, steps,
configuration and execution abstractions.
|
org.springframework.batch.core.job |
Specific implementations of job concerns.
|
org.springframework.batch.core.partition.support | |
org.springframework.batch.core.repository.dao |
Specific implementations of dao concerns.
|
org.springframework.batch.core.step |
Specific implementations of step concerns.
|
org.springframework.batch.core.step.item |
Specific implementations of step concerns for item-oriented approach.
|
org.springframework.batch.core.step.tasklet |
Interfaces and generic implementations of tasklet concerns.
|
org.springframework.batch.item |
Infrastructure interfaces and primary dependencies for item concerns.
|
org.springframework.batch.item.database |
Infrastructure implementations of database based item readers and writers.
|
org.springframework.batch.item.file |
Infrastructure implementations of io file concerns.
|
org.springframework.batch.item.support |
Internal support package
|
org.springframework.batch.item.xml |
Infrastructure implementations of xml input and output.
|
org.springframework.batch.sample.common | |
org.springframework.batch.sample.domain.trade.internal | |
org.springframework.batch.test |
Modifier and Type | Method and Description |
---|---|
ExecutionContext |
StepExecution.getExecutionContext()
Returns the
ExecutionContext for this execution |
ExecutionContext |
JobExecution.getExecutionContext()
Returns the
ExecutionContext for this execution. |
Modifier and Type | Method and Description |
---|---|
void |
StepExecution.setExecutionContext(ExecutionContext executionContext)
Sets the
ExecutionContext for this execution |
void |
JobExecution.setExecutionContext(ExecutionContext executionContext)
Sets the
ExecutionContext for this execution |
Modifier and Type | Method and Description |
---|---|
void |
SimpleStepHandler.setExecutionContext(ExecutionContext executionContext)
A context containing values to be added to the step execution before it
is handled.
|
Constructor and Description |
---|
SimpleStepHandler(JobRepository jobRepository,
ExecutionContext executionContext) |
Modifier and Type | Method and Description |
---|---|
Map<String,ExecutionContext> |
SimplePartitioner.partition(int gridSize) |
Map<String,ExecutionContext> |
Partitioner.partition(int gridSize)
Create a set of distinct
ExecutionContext instances together with
a unique identifier for each one. |
Map<String,ExecutionContext> |
MultiResourcePartitioner.partition(int gridSize)
Assign the filename of each of the injected resources to an
ExecutionContext . |
Modifier and Type | Method and Description |
---|---|
ExecutionContext |
MapExecutionContextDao.getExecutionContext(JobExecution jobExecution) |
ExecutionContext |
JdbcExecutionContextDao.getExecutionContext(JobExecution jobExecution) |
ExecutionContext |
ExecutionContextDao.getExecutionContext(JobExecution jobExecution) |
ExecutionContext |
MapExecutionContextDao.getExecutionContext(StepExecution stepExecution) |
ExecutionContext |
JdbcExecutionContextDao.getExecutionContext(StepExecution stepExecution) |
ExecutionContext |
ExecutionContextDao.getExecutionContext(StepExecution stepExecution) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractStep.close(ExecutionContext ctx)
Extension point for subclasses to provide callbacks to their collaborators at the end of a step (right at the end
of the finally block), to close or release resources.
|
protected void |
AbstractStep.open(ExecutionContext ctx)
Extension point for subclasses to provide callbacks to their collaborators at the beginning of a step, to open or
acquire resources.
|
Modifier and Type | Method and Description |
---|---|
void |
ChunkMonitor.open(ExecutionContext executionContext) |
void |
ChunkMonitor.update(ExecutionContext executionContext) |
Modifier and Type | Method and Description |
---|---|
protected void |
TaskletStep.close(ExecutionContext ctx) |
protected void |
TaskletStep.open(ExecutionContext ctx) |
Modifier and Type | Method and Description |
---|---|
void |
ItemStreamSupport.open(ExecutionContext executionContext)
No-op.
|
void |
ItemStream.open(ExecutionContext executionContext)
Open the stream for the provided
ExecutionContext . |
void |
ItemStreamSupport.update(ExecutionContext executionContext)
Return empty
ExecutionContext . |
void |
ItemStream.update(ExecutionContext executionContext)
Indicates that the execution context provided during open is about to be saved.
|
Constructor and Description |
---|
ExecutionContext(ExecutionContext executionContext) |
Modifier and Type | Method and Description |
---|---|
void |
JdbcPagingItemReader.open(ExecutionContext executionContext) |
void |
JdbcPagingItemReader.update(ExecutionContext executionContext) |
void |
HibernateCursorItemReader.update(ExecutionContext executionContext)
Update the context and clear the session if stateful.
|
Modifier and Type | Method and Description |
---|---|
void |
ResourcesItemReader.open(ExecutionContext executionContext) |
void |
MultiResourceItemWriter.open(ExecutionContext executionContext) |
void |
MultiResourceItemReader.open(ExecutionContext executionContext)
Figure out which resource to start with in case of restart, open the delegate and restore delegate's position in
the resource.
|
void |
FlatFileItemWriter.open(ExecutionContext executionContext)
Initialize the reader.
|
void |
ResourcesItemReader.update(ExecutionContext executionContext) |
void |
MultiResourceItemWriter.update(ExecutionContext executionContext) |
void |
MultiResourceItemReader.update(ExecutionContext executionContext)
Store the current resource index and position in the resource.
|
void |
FlatFileItemWriter.update(ExecutionContext executionContext) |
Modifier and Type | Method and Description |
---|---|
void |
SingleItemPeekableItemReader.open(ExecutionContext executionContext)
If the delegate is an
ItemStream , just pass the call on,
otherwise reset the peek cache. |
void |
CompositeItemWriter.open(ExecutionContext executionContext) |
void |
CompositeItemStream.open(ExecutionContext executionContext)
Broadcast the call to open.
|
void |
AbstractItemCountingItemStreamItemReader.open(ExecutionContext executionContext) |
void |
SingleItemPeekableItemReader.update(ExecutionContext executionContext)
If there is a cached peek, then retrieve the execution context state from
that point.
|
void |
CompositeItemWriter.update(ExecutionContext executionContext) |
void |
CompositeItemStream.update(ExecutionContext executionContext)
Simple aggregate
ExecutionContext provider for the contributions
registered under the given key. |
void |
AbstractItemCountingItemStreamItemReader.update(ExecutionContext executionContext) |
Modifier and Type | Method and Description |
---|---|
void |
StaxEventItemWriter.open(ExecutionContext executionContext)
Open the output source
|
void |
StaxEventItemWriter.update(ExecutionContext executionContext)
Get the restart data.
|
Modifier and Type | Method and Description |
---|---|
Map<String,ExecutionContext> |
ColumnRangePartitioner.partition(int gridSize)
Partition a database table assuming that the data in the column specified
are uniformly distributed.
|
Modifier and Type | Method and Description |
---|---|
void |
TradeWriter.open(ExecutionContext executionContext) |
void |
FlatFileCustomerCreditDao.open(ExecutionContext executionContext) |
void |
TradeWriter.update(ExecutionContext executionContext) |
Modifier and Type | Method and Description |
---|---|
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(JobParameters jobParameters,
ExecutionContext executionContext)
Create a
StepExecution and all its parent entities with default
values, but using the ExecutionContext and JobParameters
provided. |
JobExecution |
StepRunner.launchStep(Step step,
ExecutionContext jobExecutionContext)
Launch just the specified step as its own job.
|
JobExecution |
StepRunner.launchStep(Step step,
JobParameters jobParameters,
ExecutionContext jobExecutionContext)
Launch just the specified step as its own job.
|
JobExecution |
JobLauncherTestUtils.launchStep(String stepName,
ExecutionContext jobExecutionContext)
Launch just the specified step in the job.
|
JobExecution |
AbstractJobTests.launchStep(String stepName,
ExecutionContext jobExecutionContext)
Deprecated.
Launch just the specified step in the job.
|
JobExecution |
JobLauncherTestUtils.launchStep(String stepName,
JobParameters jobParameters,
ExecutionContext jobExecutionContext)
Launch just the specified step in the job.
|
JobExecution |
AbstractJobTests.launchStep(String stepName,
JobParameters jobParameters,
ExecutionContext jobExecutionContext)
Deprecated.
Launch just the specified step in the job.
|
Copyright © 2014 Pivotal. All rights reserved.