Modifier and Type | Field and Description |
---|---|
protected RuntimeJobExecution |
JobThreadRootController.jobExecution |
protected RuntimeJobExecution |
BaseStepController.jobExecutionImpl |
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 SplitController |
ExecutionElementControllerFactory.getSplitController(BatchKernelService kernel,
RuntimeJobExecution jobExecutionImpl,
Split split,
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 | Class and Description |
---|---|
class |
RuntimeFlowInSplitExecution |
Modifier and Type | Method and Description |
---|---|
static RuntimeJobExecution |
JobExecutionHelper.restartJob(ServicesManager servicesManager,
long executionId,
Properties restartJobParameters) |
static RuntimeJobExecution |
JobExecutionHelper.restartPartition(ServicesManager servicesManager,
long execId,
JSLJob gennedJobModel,
Properties partitionProps) |
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 |
---|---|
static javax.batch.api.Batchlet |
ProxyFactory.createBatchletProxy(BatchArtifactFactory factory,
String id,
InjectionReferences injectionRefs,
RuntimeJobExecution execution) |
static CheckpointAlgorithmProxy |
ProxyFactory.createCheckpointAlgorithmProxy(BatchArtifactFactory factory,
String id,
InjectionReferences injectionRefs,
RuntimeJobExecution execution) |
static javax.batch.api.Decider |
ProxyFactory.createDeciderProxy(BatchArtifactFactory factory,
String id,
InjectionReferences injectionRefs,
RuntimeJobExecution execution) |
static javax.batch.api.chunk.ItemProcessor |
ProxyFactory.createItemProcessorProxy(BatchArtifactFactory factory,
String id,
InjectionReferences injectionRefs,
RuntimeJobExecution execution) |
static javax.batch.api.chunk.ItemReader |
ProxyFactory.createItemReaderProxy(BatchArtifactFactory factory,
String id,
InjectionReferences injectionRefs,
RuntimeJobExecution execution) |
static javax.batch.api.chunk.ItemWriter |
ProxyFactory.createItemWriterProxy(BatchArtifactFactory factory,
String id,
InjectionReferences injectionRefs,
RuntimeJobExecution execution) |
static javax.batch.api.partition.PartitionAnalyzer |
ProxyFactory.createPartitionAnalyzerProxy(BatchArtifactFactory factory,
String id,
InjectionReferences injectionRefs,
RuntimeJobExecution execution) |
static javax.batch.api.partition.PartitionCollector |
ProxyFactory.createPartitionCollectorProxy(BatchArtifactFactory factory,
String id,
InjectionReferences injectionRefs,
RuntimeJobExecution execution) |
static javax.batch.api.partition.PartitionMapper |
ProxyFactory.createPartitionMapperProxy(BatchArtifactFactory factory,
String id,
InjectionReferences injectionRefs,
RuntimeJobExecution execution) |
static javax.batch.api.partition.PartitionReducer |
ProxyFactory.createPartitionReducerProxy(BatchArtifactFactory factory,
String id,
InjectionReferences injectionRefs,
RuntimeJobExecution execution) |
<T> List<T> |
ListenerFactory.getListeners(Class<T> listenerClazz,
Step step,
InjectionReferences injectionRefs,
RuntimeJobExecution execution) |
protected static Object |
ProxyFactory.loadArtifact(BatchArtifactFactory factory,
String id,
InjectionReferences injectionReferences,
RuntimeJobExecution execution) |
Constructor and Description |
---|
ListenerFactory(BatchArtifactFactory factory,
JSLJob jobModel,
InjectionReferences injectionRefs,
RuntimeJobExecution execution) |
Modifier and Type | Method and Description |
---|---|
void |
BatchKernelService.jobExecutionDone(RuntimeJobExecution jobExecution) |
Modifier and Type | Method and Description |
---|---|
void |
SimpleJobExecutionCallbackService.onJobExecutionDone(RuntimeJobExecution jobExecution) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultBatchKernel.jobExecutionDone(RuntimeJobExecution jobExecution) |
Modifier and Type | Method and Description |
---|---|
RuntimeJobExecution |
JDBCPersistenceManagerService.createJobExecution(javax.batch.runtime.JobInstance jobInstance,
Properties jobParameters,
javax.batch.runtime.BatchStatus batchStatus) |
RuntimeJobExecution |
JPAPersistenceManagerService.createJobExecution(javax.batch.runtime.JobInstance jobInstance,
Properties jobParameters,
javax.batch.runtime.BatchStatus batchStatus) |
RuntimeJobExecution |
MemoryPersistenceManagerService.createJobExecution(javax.batch.runtime.JobInstance jobInstance,
Properties jobParameters,
javax.batch.runtime.BatchStatus batchStatus) |
Modifier and Type | Field and Description |
---|---|
protected RuntimeJobExecution |
BatchWorkUnit.jobExecutionImpl |
Modifier and Type | Method and Description |
---|---|
RuntimeJobExecution |
BatchWorkUnit.getJobExecutionImpl() |
Modifier and Type | Method and Description |
---|---|
void |
BatchWorkUnit.setJobExecutionImpl(RuntimeJobExecution jobExecutionImpl) |
Constructor and Description |
---|
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 |
---|---|
RuntimeJobExecution |
PersistenceManagerService.createJobExecution(javax.batch.runtime.JobInstance jobInstance,
Properties jobParameters,
javax.batch.runtime.BatchStatus batchStatus)
Create a JobExecution
|
Modifier and Type | Method and Description |
---|---|
void |
JobExecutionCallbackService.onJobExecutionDone(RuntimeJobExecution jobExecution) |
Constructor and Description |
---|
Result(StepContextImpl stepContext,
RuntimeJobExecution jobExecution,
PersistenceManagerService persistenceManagerService) |
Copyright © 2017 The Apache Software Foundation. All rights reserved.