Class DefaultBatchKernel
- java.lang.Object
-
- org.apache.batchee.container.services.kernel.DefaultBatchKernel
-
- All Implemented Interfaces:
BatchKernelService,BatchService
public class DefaultBatchKernel extends Object implements BatchKernelService
-
-
Constructor Summary
Constructors Constructor Description DefaultBatchKernel(ServicesManager servicesManager)
-
Method Summary
-
-
-
Constructor Detail
-
DefaultBatchKernel
public DefaultBatchKernel(ServicesManager servicesManager)
-
-
Method Detail
-
init
public void init(Properties pgcConfig) throws BatchContainerServiceException
- Specified by:
initin interfaceBatchService- Throws:
BatchContainerServiceException
-
startJob
public InternalJobExecution startJob(String jobXML, Properties jobParameters) throws javax.batch.operations.JobStartException
- Specified by:
startJobin interfaceBatchKernelService- Throws:
javax.batch.operations.JobStartException
-
stopJob
public void stopJob(long executionId) throws javax.batch.operations.NoSuchJobExecutionException, javax.batch.operations.JobExecutionNotRunningException- Specified by:
stopJobin interfaceBatchKernelService- Throws:
javax.batch.operations.NoSuchJobExecutionExceptionjavax.batch.operations.JobExecutionNotRunningException
-
restartJob
public InternalJobExecution restartJob(long executionId, Properties jobOverrideProps) throws javax.batch.operations.JobRestartException, javax.batch.operations.JobExecutionAlreadyCompleteException, javax.batch.operations.JobExecutionNotMostRecentException, javax.batch.operations.NoSuchJobExecutionException
- Specified by:
restartJobin interfaceBatchKernelService- Throws:
javax.batch.operations.JobRestartExceptionjavax.batch.operations.JobExecutionAlreadyCompleteExceptionjavax.batch.operations.JobExecutionNotMostRecentExceptionjavax.batch.operations.NoSuchJobExecutionException
-
jobExecutionDone
public void jobExecutionDone(RuntimeJobExecution jobExecution)
- Specified by:
jobExecutionDonein interfaceBatchKernelService
-
getJobExecution
public InternalJobExecution getJobExecution(long executionId) throws javax.batch.operations.NoSuchJobExecutionException
- Specified by:
getJobExecutionin interfaceBatchKernelService- Throws:
javax.batch.operations.NoSuchJobExecutionException
-
startGeneratedJob
public void startGeneratedJob(BatchWorkUnit batchWork)
- Specified by:
startGeneratedJobin interfaceBatchKernelService
-
getJobInstanceCount
public int getJobInstanceCount(String jobName)
- Specified by:
getJobInstanceCountin interfaceBatchKernelService
-
getJobInstance
public javax.batch.runtime.JobInstance getJobInstance(long executionId)
- Specified by:
getJobInstancein interfaceBatchKernelService
-
buildNewParallelPartitions
public List<BatchPartitionWorkUnit> buildNewParallelPartitions(PartitionsBuilderConfig config, JobContextImpl jc, StepContextImpl sc) throws javax.batch.operations.JobRestartException, javax.batch.operations.JobStartException
Build a list of batch work units and set them up in STARTING state but don't start them yet.- Specified by:
buildNewParallelPartitionsin interfaceBatchKernelService- Throws:
javax.batch.operations.JobRestartExceptionjavax.batch.operations.JobStartException
-
buildOnRestartParallelPartitions
public List<BatchPartitionWorkUnit> buildOnRestartParallelPartitions(PartitionsBuilderConfig config, JobContextImpl jc, StepContextImpl sc) throws javax.batch.operations.JobRestartException, javax.batch.operations.JobExecutionAlreadyCompleteException, javax.batch.operations.JobExecutionNotMostRecentException
- Specified by:
buildOnRestartParallelPartitionsin interfaceBatchKernelService- Throws:
javax.batch.operations.JobRestartExceptionjavax.batch.operations.JobExecutionAlreadyCompleteExceptionjavax.batch.operations.JobExecutionNotMostRecentException
-
restartGeneratedJob
public void restartGeneratedJob(BatchWorkUnit batchWork) throws javax.batch.operations.JobRestartException
- Specified by:
restartGeneratedJobin interfaceBatchKernelService- Throws:
javax.batch.operations.JobRestartException
-
buildNewFlowInSplitWorkUnit
public BatchFlowInSplitWorkUnit buildNewFlowInSplitWorkUnit(FlowInSplitBuilderConfig config, JobContextImpl jc)
- Specified by:
buildNewFlowInSplitWorkUnitin interfaceBatchKernelService
-
buildOnRestartFlowInSplitWorkUnit
public BatchFlowInSplitWorkUnit buildOnRestartFlowInSplitWorkUnit(FlowInSplitBuilderConfig config, JobContextImpl jc) throws javax.batch.operations.JobRestartException, javax.batch.operations.JobExecutionAlreadyCompleteException, javax.batch.operations.JobExecutionNotMostRecentException
- Specified by:
buildOnRestartFlowInSplitWorkUnitin interfaceBatchKernelService- Throws:
javax.batch.operations.JobRestartExceptionjavax.batch.operations.JobExecutionAlreadyCompleteExceptionjavax.batch.operations.JobExecutionNotMostRecentException
-
isExecutionRunning
public boolean isExecutionRunning(long executionId)
- Specified by:
isExecutionRunningin interfaceBatchKernelService
-
-