public interface PersistenceManagerService extends BatchService
Modifier and Type | Interface and Description |
---|---|
static class |
PersistenceManagerService.TimestampType |
Modifier and Type | Method and Description |
---|---|
void |
cleanUp(Date until) |
void |
cleanUp(long instanceId) |
RuntimeFlowInSplitExecution |
createFlowInSplitExecution(javax.batch.runtime.JobInstance jobInstance,
javax.batch.runtime.BatchStatus batchStatus) |
RuntimeJobExecution |
createJobExecution(javax.batch.runtime.JobInstance jobInstance,
Properties jobParameters,
javax.batch.runtime.BatchStatus batchStatus)
Create a JobExecution
|
javax.batch.runtime.JobInstance |
createJobInstance(String name,
String jobXml)
Creates a JobIntance
|
JobStatus |
createJobStatus(long jobInstanceId)
Create a JobStatus
|
StepExecutionImpl |
createStepExecution(long jobExecId,
StepContextImpl stepContext)
Create a StepExecution
|
StepStatus |
createStepStatus(long stepExecId)
Create a StepStatus
|
javax.batch.runtime.JobInstance |
createSubJobInstance(String name) |
CheckpointData |
getCheckpointData(CheckpointDataKey key) |
long |
getJobInstanceIdByExecutionId(long executionId) |
Set<String> |
getJobNames() |
JobStatus |
getJobStatus(long instanceId)
Get a JobStatus
|
JobStatus |
getJobStatusFromExecution(long executionId) |
long |
getMostRecentExecutionId(long jobInstanceId) |
Properties |
getParameters(long executionId) |
javax.batch.runtime.StepExecution |
getStepExecutionByStepExecutionId(long stepExecId) |
List<javax.batch.runtime.StepExecution> |
getStepExecutionsForJobExecution(long execid) |
StepStatus |
getStepStatus(long instanceId,
String stepName)
Get a StepStatus
The parent job instance id and this step name from the job xml
are used to determine if the current step execution have previously run.
|
InternalJobExecution |
jobOperatorGetJobExecution(long jobExecutionId) |
List<InternalJobExecution> |
jobOperatorGetJobExecutions(long jobInstanceId) |
int |
jobOperatorGetJobInstanceCount(String jobName)
JOB OPERATOR ONLY METHODS
|
List<Long> |
jobOperatorGetJobInstanceIds(String jobName,
int start,
int count) |
Set<Long> |
jobOperatorGetRunningExecutions(String jobName) |
String |
jobOperatorQueryJobExecutionBatchStatus(long key) |
String |
jobOperatorQueryJobExecutionExitStatus(long key) |
Timestamp |
jobOperatorQueryJobExecutionTimestamp(long key,
PersistenceManagerService.TimestampType timetype) |
void |
markJobStarted(long key,
Timestamp startTS) |
void |
setCheckpointData(CheckpointDataKey key,
CheckpointData value) |
void |
updateBatchStatusOnly(long executionId,
javax.batch.runtime.BatchStatus batchStatus,
Timestamp timestamp) |
void |
updateJobStatus(long instanceId,
JobStatus jobStatus)
Update a JobStatus
|
void |
updateStepExecution(long jobExecId,
StepContextImpl stepContext)
Update a StepExecution
|
void |
updateStepStatus(long stepExecutionId,
StepStatus stepStatus)
Update a StepStatus
|
void |
updateWithFinalExecutionStatusesAndTimestamps(long key,
javax.batch.runtime.BatchStatus batchStatus,
String exitStatus,
Timestamp updatets) |
init
int jobOperatorGetJobInstanceCount(String jobName)
List<Long> jobOperatorGetJobInstanceIds(String jobName, int start, int count)
Timestamp jobOperatorQueryJobExecutionTimestamp(long key, PersistenceManagerService.TimestampType timetype)
String jobOperatorQueryJobExecutionBatchStatus(long key)
String jobOperatorQueryJobExecutionExitStatus(long key)
List<javax.batch.runtime.StepExecution> getStepExecutionsForJobExecution(long execid)
void updateBatchStatusOnly(long executionId, javax.batch.runtime.BatchStatus batchStatus, Timestamp timestamp)
void markJobStarted(long key, Timestamp startTS)
void updateWithFinalExecutionStatusesAndTimestamps(long key, javax.batch.runtime.BatchStatus batchStatus, String exitStatus, Timestamp updatets)
InternalJobExecution jobOperatorGetJobExecution(long jobExecutionId)
Properties getParameters(long executionId) throws javax.batch.operations.NoSuchJobExecutionException
javax.batch.operations.NoSuchJobExecutionException
List<InternalJobExecution> jobOperatorGetJobExecutions(long jobInstanceId)
JobStatus getJobStatusFromExecution(long executionId)
long getJobInstanceIdByExecutionId(long executionId) throws javax.batch.operations.NoSuchJobExecutionException
javax.batch.operations.NoSuchJobExecutionException
javax.batch.runtime.JobInstance createJobInstance(String name, String jobXml)
name
- the job id from job.xmljobXml
- the resolved job xmlRuntimeJobExecution createJobExecution(javax.batch.runtime.JobInstance jobInstance, Properties jobParameters, javax.batch.runtime.BatchStatus batchStatus)
jobInstance
- the parent job instancejobParameters
- the parent job instance parametersbatchStatus
- the current BatchStatusStepExecutionImpl createStepExecution(long jobExecId, StepContextImpl stepContext)
jobExecId
- the parent JobExecution idstepContext
- the step context for this step executionvoid updateStepExecution(long jobExecId, StepContextImpl stepContext)
jobExecId
- the parent JobExecution idstepContext
- the step context for this step executionJobStatus createJobStatus(long jobInstanceId)
jobInstanceId
- the parent job instance idJobStatus getJobStatus(long instanceId)
instanceId
- the parent job instance idvoid updateJobStatus(long instanceId, JobStatus jobStatus)
instanceId
- the parent job instance idjobStatus
- the job status to be updatedStepStatus createStepStatus(long stepExecId)
stepExecId
- the parent step execution idStepStatus getStepStatus(long instanceId, String stepName)
The parent job instance id and this step name from the job xml are used to determine if the current step execution have previously run.
instanceId
- the parent job instance idstepName
- the step namevoid updateStepStatus(long stepExecutionId, StepStatus stepStatus)
stepExecutionId
- the parent step execution idstepStatus
- the step status to be updatedvoid setCheckpointData(CheckpointDataKey key, CheckpointData value)
CheckpointData getCheckpointData(CheckpointDataKey key)
long getMostRecentExecutionId(long jobInstanceId)
javax.batch.runtime.JobInstance createSubJobInstance(String name)
RuntimeFlowInSplitExecution createFlowInSplitExecution(javax.batch.runtime.JobInstance jobInstance, javax.batch.runtime.BatchStatus batchStatus)
javax.batch.runtime.StepExecution getStepExecutionByStepExecutionId(long stepExecId)
void cleanUp(long instanceId)
void cleanUp(Date until)
Copyright © 2017 The Apache Software Foundation. All rights reserved.