public class DefaultBatchKernel extends Object implements BatchKernelService
Constructor and Description |
---|
DefaultBatchKernel(ServicesManager servicesManager) |
public DefaultBatchKernel(ServicesManager servicesManager)
public void init(Properties pgcConfig) throws BatchContainerServiceException
init
in interface BatchService
BatchContainerServiceException
public InternalJobExecution startJob(String jobXML, Properties jobParameters) throws javax.batch.operations.JobStartException
startJob
in interface BatchKernelService
javax.batch.operations.JobStartException
public void stopJob(long executionId) throws javax.batch.operations.NoSuchJobExecutionException, javax.batch.operations.JobExecutionNotRunningException
stopJob
in interface BatchKernelService
javax.batch.operations.NoSuchJobExecutionException
javax.batch.operations.JobExecutionNotRunningException
public InternalJobExecution restartJob(long executionId, Properties jobOverrideProps) throws javax.batch.operations.JobRestartException, javax.batch.operations.JobExecutionAlreadyCompleteException, javax.batch.operations.JobExecutionNotMostRecentException, javax.batch.operations.NoSuchJobExecutionException
restartJob
in interface BatchKernelService
javax.batch.operations.JobRestartException
javax.batch.operations.JobExecutionAlreadyCompleteException
javax.batch.operations.JobExecutionNotMostRecentException
javax.batch.operations.NoSuchJobExecutionException
public void jobExecutionDone(RuntimeJobExecution jobExecution)
jobExecutionDone
in interface BatchKernelService
public InternalJobExecution getJobExecution(long executionId) throws javax.batch.operations.NoSuchJobExecutionException
getJobExecution
in interface BatchKernelService
javax.batch.operations.NoSuchJobExecutionException
public void startGeneratedJob(BatchWorkUnit batchWork)
startGeneratedJob
in interface BatchKernelService
public int getJobInstanceCount(String jobName)
getJobInstanceCount
in interface BatchKernelService
public javax.batch.runtime.JobInstance getJobInstance(long executionId)
getJobInstance
in interface BatchKernelService
public List<BatchPartitionWorkUnit> buildNewParallelPartitions(PartitionsBuilderConfig config, JobContextImpl jc, StepContextImpl sc) throws javax.batch.operations.JobRestartException, javax.batch.operations.JobStartException
buildNewParallelPartitions
in interface BatchKernelService
javax.batch.operations.JobRestartException
javax.batch.operations.JobStartException
public List<BatchPartitionWorkUnit> buildOnRestartParallelPartitions(PartitionsBuilderConfig config, JobContextImpl jc, StepContextImpl sc) throws javax.batch.operations.JobRestartException, javax.batch.operations.JobExecutionAlreadyCompleteException, javax.batch.operations.JobExecutionNotMostRecentException
buildOnRestartParallelPartitions
in interface BatchKernelService
javax.batch.operations.JobRestartException
javax.batch.operations.JobExecutionAlreadyCompleteException
javax.batch.operations.JobExecutionNotMostRecentException
public void restartGeneratedJob(BatchWorkUnit batchWork) throws javax.batch.operations.JobRestartException
restartGeneratedJob
in interface BatchKernelService
javax.batch.operations.JobRestartException
public BatchFlowInSplitWorkUnit buildNewFlowInSplitWorkUnit(FlowInSplitBuilderConfig config, JobContextImpl jc)
buildNewFlowInSplitWorkUnit
in interface BatchKernelService
public BatchFlowInSplitWorkUnit buildOnRestartFlowInSplitWorkUnit(FlowInSplitBuilderConfig config, JobContextImpl jc) throws javax.batch.operations.JobRestartException, javax.batch.operations.JobExecutionAlreadyCompleteException, javax.batch.operations.JobExecutionNotMostRecentException
buildOnRestartFlowInSplitWorkUnit
in interface BatchKernelService
javax.batch.operations.JobRestartException
javax.batch.operations.JobExecutionAlreadyCompleteException
javax.batch.operations.JobExecutionNotMostRecentException
public boolean isExecutionRunning(long executionId)
isExecutionRunning
in interface BatchKernelService
Copyright © 2017 The Apache Software Foundation. All rights reserved.