Package | Description |
---|---|
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.impl.jobinstance | |
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.locator | |
org.apache.batchee.container.services.status | |
org.apache.batchee.container.util | |
org.apache.batchee.tools.maven.locator |
Constructor and Description |
---|
JobOperatorImpl(ServicesManager servicesManager) |
Modifier and Type | Field and Description |
---|---|
protected ServicesManager |
JobThreadRootController.manager |
Modifier and Type | Method and Description |
---|---|
static DecisionController |
ExecutionElementControllerFactory.getDecisionController(ServicesManager servicesManager,
RuntimeJobExecution jobExecutionImpl,
Decision decision) |
static FlowController |
ExecutionElementControllerFactory.getFlowController(ServicesManager servicesManager,
RuntimeJobExecution jobExecutionImpl,
Flow flow,
long rootJobExecutionId) |
static BaseStepController |
ExecutionElementControllerFactory.getStepController(RuntimeJobExecution jobExecutionImpl,
Step step,
StepContextImpl stepContext,
long rootJobExecutionId,
BlockingQueue<PartitionDataWrapper> analyzerQueue,
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 | Method and Description |
---|---|
static RuntimeFlowInSplitExecution |
JobExecutionHelper.restartFlowInSplit(ServicesManager servicesManager,
long execId,
JSLJob gennedJobModel) |
static RuntimeJobExecution |
JobExecutionHelper.restartJob(ServicesManager servicesManager,
long executionId,
Properties restartJobParameters) |
static RuntimeJobExecution |
JobExecutionHelper.restartPartition(ServicesManager servicesManager,
long execId,
JSLJob gennedJobModel,
Properties partitionProps) |
static RuntimeFlowInSplitExecution |
JobExecutionHelper.startFlowInSplit(ServicesManager servicesManager,
JSLJob jobModel) |
static RuntimeJobExecution |
JobExecutionHelper.startJob(ServicesManager servicesManager,
String jobXML,
Properties jobParameters) |
static RuntimeJobExecution |
JobExecutionHelper.startPartition(ServicesManager servicesManager,
JSLJob jobModel,
Properties jobParameters) |
Modifier and Type | Method and Description |
---|---|
ServicesManager |
ServicesManagerLocator.find() |
static ServicesManager |
ServicesManager.find() |
Constructor and Description |
---|
DefaultBatchKernel(ServicesManager servicesManager) |
Modifier and Type | Method and Description |
---|---|
ServicesManager |
ClassLoaderLocator.find() |
ServicesManager |
SingletonLocator.find() |
static ServicesManager |
ClassLoaderLocator.resetServiceManager(ClassLoader key) |
Modifier and Type | Method and Description |
---|---|
static void |
ClassLoaderLocator.setServiceManager(ClassLoader key,
ServicesManager manager) |
Constructor and Description |
---|
DefaultJobStatusManager(ServicesManager servicesManager) |
Constructor and Description |
---|
BatchFlowInSplitWorkUnit(RuntimeFlowInSplitExecution jobExecution,
FlowInSplitBuilderConfig config,
ServicesManager manager) |
BatchParallelWorkUnit(RuntimeJobExecution jobExecutionImpl,
boolean notifyCallbackWhenDone,
ServicesManager manager) |
BatchPartitionWorkUnit(RuntimeJobExecution jobExecution,
PartitionsBuilderConfig config,
ServicesManager manager) |
BatchWorkUnit(ServicesManager manager,
RuntimeJobExecution jobExecutionImpl) |
BatchWorkUnit(ServicesManager manager,
RuntimeJobExecution jobExecutionImpl,
boolean notifyCallbackWhenDone) |
Modifier and Type | Method and Description |
---|---|
ServicesManager |
MavenPluginLocator.find() |
Copyright © 2021 The Apache Software Foundation. All rights reserved.