Package | Description |
---|---|
org.apache.batchee.container | |
org.apache.batchee.container.impl | |
org.apache.batchee.container.impl.controller | |
org.apache.batchee.container.impl.controller.batchlet | |
org.apache.batchee.container.impl.controller.chunk | |
org.apache.batchee.container.proxy | |
org.apache.batchee.container.services |
This interfaces are tightly coupled to the existing
batch implementation.
|
org.apache.batchee.container.services.kernel | |
org.apache.batchee.container.services.persistence | |
org.apache.batchee.container.util | |
org.apache.batchee.spi | |
org.apache.batchee.test |
Modifier and Type | Method and Description |
---|---|
void |
ThreadRootController.setParentStepContext(StepContextImpl stepContext) |
Modifier and Type | Method and Description |
---|---|
void |
StepExecutionImpl.setStepContext(StepContextImpl stepContext) |
Modifier and Type | Field and Description |
---|---|
protected StepContextImpl |
JobThreadRootController.parentStepContext |
protected StepContextImpl |
BaseStepController.stepContext |
Modifier and Type | Method and Description |
---|---|
static BaseStepController |
ExecutionElementControllerFactory.getStepController(RuntimeJobExecution jobExecutionImpl,
Step step,
StepContextImpl stepContext,
long rootJobExecutionId,
BlockingQueue<PartitionDataWrapper> analyzerQueue,
ServicesManager servicesManager) |
void |
BaseStepController.setParentStepContext(StepContextImpl parentStepContext) |
void |
ExecutionTransitioner.setParentStepContext(StepContextImpl parentStepContext) |
void |
JobThreadRootController.setParentStepContext(StepContextImpl parentStepContext) |
void |
BaseStepController.setStepContext(StepContextImpl stepContext) |
Constructor and Description |
---|
BaseStepController(RuntimeJobExecution jobExecution,
Step step,
StepContextImpl stepContext,
long rootJobExecutionId,
BlockingQueue<PartitionDataWrapper> analyzerStatusQueue,
ServicesManager servicesManager) |
BaseStepController(RuntimeJobExecution jobExecution,
Step step,
StepContextImpl stepContext,
long rootJobExecutionId,
ServicesManager servicesManager) |
PartitionedStepController(RuntimeJobExecution jobExecutionImpl,
Step step,
StepContextImpl stepContext,
long rootJobExecutionId,
ServicesManager servicesManager) |
SingleThreadedStepController(RuntimeJobExecution jobExecutionImpl,
Step step,
StepContextImpl stepContext,
long rootJobExecutionId,
BlockingQueue<PartitionDataWrapper> analyzerStatusQueue,
ServicesManager servicesManager) |
Constructor and Description |
---|
BatchletStepController(RuntimeJobExecution jobExecutionImpl,
Step step,
StepContextImpl stepContext,
long rootJobExecutionId,
BlockingQueue<PartitionDataWrapper> analyzerStatusQueue,
ServicesManager manager) |
Constructor and Description |
---|
ChunkStepController(RuntimeJobExecution jobExecutionImpl,
Step step,
StepContextImpl stepContext,
long rootJobExecutionId,
BlockingQueue<PartitionDataWrapper> analyzerStatusQueue,
ServicesManager servicesManager) |
Modifier and Type | Field and Description |
---|---|
protected StepContextImpl |
AbstractProxy.stepContext |
Modifier and Type | Method and Description |
---|---|
StepContextImpl |
InjectionReferences.getStepContext() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractProxy.setStepContext(StepContextImpl stepContext) |
Constructor and Description |
---|
InjectionReferences(JobContextImpl jobContext,
StepContextImpl stepContext,
List<Property> props) |
Modifier and Type | Method and Description |
---|---|
List<BatchPartitionWorkUnit> |
BatchKernelService.buildNewParallelPartitions(PartitionsBuilderConfig config,
JobContextImpl jc,
StepContextImpl sc) |
List<BatchPartitionWorkUnit> |
BatchKernelService.buildOnRestartParallelPartitions(PartitionsBuilderConfig config,
JobContextImpl jc,
StepContextImpl sc) |
Modifier and Type | Method and Description |
---|---|
List<BatchPartitionWorkUnit> |
DefaultBatchKernel.buildNewParallelPartitions(PartitionsBuilderConfig config,
JobContextImpl jc,
StepContextImpl sc)
Build a list of batch work units and set them up in STARTING state but don't start them yet.
|
List<BatchPartitionWorkUnit> |
DefaultBatchKernel.buildOnRestartParallelPartitions(PartitionsBuilderConfig config,
JobContextImpl jc,
StepContextImpl sc) |
Modifier and Type | Method and Description |
---|---|
StepExecutionImpl |
JDBCPersistenceManagerService.createStepExecution(long rootJobExecId,
StepContextImpl stepContext) |
StepExecutionImpl |
JPAPersistenceManagerService.createStepExecution(long jobExecId,
StepContextImpl stepContext) |
StepExecutionImpl |
MemoryPersistenceManagerService.createStepExecution(long rootJobExecId,
StepContextImpl stepContext) |
void |
JDBCPersistenceManagerService.updateStepExecution(long rootJobExecId,
StepContextImpl stepContext) |
void |
JPAPersistenceManagerService.updateStepExecution(long jobExecId,
StepContextImpl stepContext) |
void |
MemoryPersistenceManagerService.updateStepExecution(long jobExecId,
StepContextImpl stepContext) |
Modifier and Type | Method and Description |
---|---|
void |
BatchPartitionWorkUnit.inheritStepContext(StepContextImpl sc) |
Modifier and Type | Method and Description |
---|---|
StepExecutionImpl |
PersistenceManagerService.createStepExecution(long jobExecId,
StepContextImpl stepContext)
Create a StepExecution
|
void |
PersistenceManagerService.updateStepExecution(long jobExecId,
StepContextImpl stepContext)
Update a StepExecution
|
Constructor and Description |
---|
Result(StepContextImpl stepContext,
RuntimeJobExecution jobExecution,
PersistenceManagerService persistenceManagerService) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.