org.jberet.runtime

Class JobExecutionImpl

java.lang.Object

org.jberet.runtime.AbstractExecution

org.jberet.runtime.JobExecutionImpl

All Implemented Interfaces:

Serializable, Cloneable, javax.batch.runtime.JobExecution

public final class JobExecutionImpl
extends AbstractExecution
implements javax.batch.runtime.JobExecution, Cloneable

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected long	createTime
protected long	lastUpdatedTime

Fields inherited from class org.jberet.runtime.AbstractExecution

batchStatus, endTime, exitStatus, startTime, version

Constructor Summary

Constructors

Constructor and Description
JobExecutionImpl(JobInstanceImpl jobInstance, long id, Properties jobParameters, Date createTime, Date startTime, Date endTime, Date lastUpdatedTime, String batchStatus, String exitStatus, String restartPositionAndUser)
JobExecutionImpl(JobInstanceImpl jobInstance, Properties jobParameters)

Method Summary

Modifier and Type	Method and Description
void	addJobParameter(String k, String v) Adds job parameter key-value pair.
void	addStepExecution(javax.batch.runtime.StepExecution stepExecution)
void	awaitTermination(long timeout, TimeUnit timeUnit)
void	cleanUp()
JobExecutionImpl	clone()
String	combineRestartPositionAndUser() Combines user and restart position into one single string value.
boolean	equals(Object o)
Date	getCreateTime()
long	getExecutionId()
JobInstanceImpl	getJobInstance()
String	getJobName()
Properties	getJobParameters()
Date	getLastUpdatedTime()
String	getRestartPosition() Gets the restart position for subsequent restart operation.
List<javax.batch.runtime.StepExecution>	getStepExecutions()
Job	getSubstitutedJob()
String	getUser() Gets the user who started this job execution.
int	hashCode()
boolean	isStopRequested()
void	registerJobStopNotifier(JobStopNotificationListener l)
void	setBatchStatus(javax.batch.runtime.BatchStatus batchStatus)
void	setId(long id)
void	setLastUpdatedTime(long lastUpdatedTime)
void	setRestartPosition(String restartPosition) Sets the restart position for subsequent restart operation.
void	setUser(String user) Sets the user who started this job execution.
void	stop()
void	unregisterJobStopNotifier(JobStopNotificationListener l)

Methods inherited from class org.jberet.runtime.AbstractExecution

getBatchStatus, getEndTime, getExitStatus, getStartTime, setExitStatus

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface javax.batch.runtime.JobExecution

getBatchStatus, getEndTime, getExitStatus, getStartTime

Field Detail

createTime

protected long createTime

lastUpdatedTime

protected long lastUpdatedTime

Constructor Detail

JobExecutionImpl

public JobExecutionImpl(JobInstanceImpl jobInstance,
                        Properties jobParameters)
                 throws javax.batch.operations.JobStartException

Throws:

javax.batch.operations.JobStartException

JobExecutionImpl

public JobExecutionImpl(JobInstanceImpl jobInstance,
                        long id,
                        Properties jobParameters,
                        Date createTime,
                        Date startTime,
                        Date endTime,
                        Date lastUpdatedTime,
                        String batchStatus,
                        String exitStatus,
                        String restartPositionAndUser)

Method Detail

setId

public void setId(long id)

clone

public JobExecutionImpl clone()

Overrides:

clone in class AbstractExecution

awaitTermination

public void awaitTermination(long timeout,
                             TimeUnit timeUnit)
                      throws InterruptedException

Throws:

InterruptedException

getSubstitutedJob

public Job getSubstitutedJob()

setBatchStatus

public void setBatchStatus(javax.batch.runtime.BatchStatus batchStatus)

Overrides:

setBatchStatus in class AbstractExecution

getExecutionId

public long getExecutionId()

Specified by:

getExecutionId in interface javax.batch.runtime.JobExecution

getJobName

public String getJobName()

Specified by:

getJobName in interface javax.batch.runtime.JobExecution

getCreateTime

public Date getCreateTime()

Specified by:

getCreateTime in interface javax.batch.runtime.JobExecution

getLastUpdatedTime

public Date getLastUpdatedTime()

Specified by:

getLastUpdatedTime in interface javax.batch.runtime.JobExecution

getJobInstance

public JobInstanceImpl getJobInstance()

getJobParameters

public Properties getJobParameters()

Specified by:

getJobParameters in interface javax.batch.runtime.JobExecution

addJobParameter

public void addJobParameter(String k,
                            String v)

Adds job parameter key-value pair. Should only be used to add internal job parameters.

Parameters:

k - key of the job parameter

v - value of the job parameter

getStepExecutions

public List<javax.batch.runtime.StepExecution> getStepExecutions()

addStepExecution

public void addStepExecution(javax.batch.runtime.StepExecution stepExecution)

setRestartPosition

public void setRestartPosition(String restartPosition)

Sets the restart position for subsequent restart operation. When set to null, the default restarting behavior is used.

Parameters:

restartPosition - the restart position; may be null

getRestartPosition

public String getRestartPosition()

Gets the restart position for subsequent restart operation. If null is returned, the default restarting behavior is used.

Returns:

the restart position; may be null

getUser

public String getUser()

Gets the user who started this job execution.

Returns:

the user who started this job execution; may be null

Since:

1.2.2, 1.3.0.Beta4

setUser

public void setUser(String user)

Sets the user who started this job execution.

Parameters:

user - the user who started this job execution; may be null

Since:

1.2.2, 1.3.0.Beta4

combineRestartPositionAndUser

public String combineRestartPositionAndUser()

Combines user and restart position into one single string value. Both user and restart position may be absent. Example values can be:

• null
• step1"user1
• step1
• "user1

Returns:

the combined value of user and restart position

Since:

1.2.2, 1.3.0.Beta4

isStopRequested

public boolean isStopRequested()

stop

public void stop()

registerJobStopNotifier

public void registerJobStopNotifier(JobStopNotificationListener l)

unregisterJobStopNotifier

public void unregisterJobStopNotifier(JobStopNotificationListener l)

setLastUpdatedTime

public void setLastUpdatedTime(long lastUpdatedTime)

cleanUp

public void cleanUp()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object