Generic implementation of IStepExecutionSplitter that delegates to a IPartitioner to generate ExecutionContext instances. Takes care of restartability and identifying the step executions from previous runs of the same job. The generated StepExecution instances have names that identify them uniquely in the partition. The name is constructed from a base (name of the target step) plus a suffix taken from the IPartitioner identifiers, separated by a colon, e.g. More...
Public Member Functions | |
SimpleStepExecutionSplitter () | |
Default constructor for convenience in configuration. More... | |
SimpleStepExecutionSplitter (IJobRepository jobRepository, bool allowStartIfComplete, string stepName, IPartitioner partitioner) | |
Constructs a SimpleStepExecutionSplitter from its mandatory properties. More... | |
void | AfterPropertiesSet () |
Post-init checks. IInitializationPostOperations::AfterPropertiesSet . More... | |
HashSet< StepExecution > | Split (StepExecution stepExecution, int gridSize) |
see IStepExecutionSplitter::Split . More... | |
Protected Member Functions | |
bool | GetStartable (StepExecution stepExecution, ExecutionContext context) |
Should it start ? More... | |
Properties | |
string | StepName [get, set] |
Step name property. More... | |
IPartitioner | Partitioner [set] |
Partitioner property. More... | |
IJobRepository | JobRepository [set] |
Job repository property. More... | |
bool | AllowStartIfComplete [set] |
Flag to indicate whether start if complete is allowed or not. More... | |
Properties inherited from Summer.Batch.Core.Partition.IStepExecutionSplitter | |
string | StepName [get, set] |
The name of the step configuration that will be executed remotely. Remote workers are going to execute a the same step for each execution context in the partition. More... | |
Detailed Description
Generic implementation of IStepExecutionSplitter that delegates to a IPartitioner to generate ExecutionContext instances. Takes care of restartability and identifying the step executions from previous runs of the same job. The generated StepExecution instances have names that identify them uniquely in the partition. The name is constructed from a base (name of the target step) plus a suffix taken from the IPartitioner identifiers, separated by a colon, e.g.
{step1:partition0, step1:partition1, ...}
.
Constructor & Destructor Documentation
Summer.Batch.Core.Partition.Support.SimpleStepExecutionSplitter.SimpleStepExecutionSplitter | ( | ) |
Default constructor for convenience in configuration.
Summer.Batch.Core.Partition.Support.SimpleStepExecutionSplitter.SimpleStepExecutionSplitter | ( | IJobRepository | jobRepository, |
bool | allowStartIfComplete, | ||
string | stepName, | ||
IPartitioner | partitioner | ||
) |
Constructs a SimpleStepExecutionSplitter from its mandatory properties.
- Parameters
-
jobRepository allowStartIfComplete flag specifying preferences on restart stepName partitioner a IPartitioner to use for generating input parameters
Member Function Documentation
void Summer.Batch.Core.Partition.Support.SimpleStepExecutionSplitter.AfterPropertiesSet | ( | ) |
Post-init checks. IInitializationPostOperations::AfterPropertiesSet .
- Exceptions
-
Exception
Implements Summer.Batch.Common.Factory.IInitializationPostOperations.
|
protected |
HashSet<StepExecution> Summer.Batch.Core.Partition.Support.SimpleStepExecutionSplitter.Split | ( | StepExecution | stepExecution, |
int | gridSize | ||
) |
see IStepExecutionSplitter::Split .
- Parameters
-
stepExecution gridSize
- Returns
Implements Summer.Batch.Core.Partition.IStepExecutionSplitter.
Property Documentation
|
set |
Flag to indicate whether start if complete is allowed or not.
|
set |
Job repository property.
|
set |
Partitioner property.
|
getset |
Step name property.
The documentation for this class was generated from the following file:
- Summer.Batch.Core/Core/Partition/Support/SimpleStepExecutionSplitter.cs