org.pentaho.di.job

Class Job

java.lang.Object

java.lang.Thread

org.pentaho.di.job.Job

All Implemented Interfaces:

Runnable, ExecutorInterface, ExtensionDataInterface, HasLogChannelInterface, LoggingObjectInterface, NamedParams, VariableSpace

public class Job
extends Thread
implements VariableSpace, NamedParams, HasLogChannelInterface, LoggingObjectInterface, ExecutorInterface, ExtensionDataInterface

This class executes a job as defined by a JobMeta object.

The definition of a PDI job is represented by a JobMeta object. It is typically loaded from a .kjb file, a PDI repository, or it is generated dynamically. The declared parameters of the job definition are then queried using listParameters() and assigned values using calls to setParameterValue(..).

Since:

07-apr-2003

Author:

Matt Casters

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected String[]	arguments The command line arguments for the job.
static String	CONFIGURATION_IN_EXPORT_FILENAME
protected Job	parentJob The job that's launching this (sub-) job.
protected Trans	parentTrans The parent transformation

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
Job()
Job(Repository repository, JobMeta jobMeta)
Job(Repository repository, JobMeta jobMeta, LoggingObjectInterface parentLogging)
Job(String name, String file, String[] args)

Method Summary

Modifier and Type	Method and Description
void	activateParameters()
void	addDelegationListener(DelegationListener delegationListener)
void	addErrors(int nrToAdd) Add a number of errors to the total number of erros that occured during execution.
void	addJobEntryListener(JobEntryListener jobEntryListener)
void	addJobListener(JobListener jobListener)
void	addParameterDefinition(String key, String defValue, String description)
boolean	beginProcessing() Handle logging at start
void	clearParameters()
void	copyParametersFrom(NamedParams params)
void	copyVariablesFrom(VariableSpace space)
protected Database	createDataBase(DatabaseMeta databaseMeta)
static Job	createJobWithNewClassLoader()
String	environmentSubstitute(String aString)
String[]	environmentSubstitute(String[] aString)
void	eraseParameters()
Result	execute(int nr, Result result) Execute a job with previous results passed in. Execute called by JobEntryJob: don't clear the jobEntryResults.
String	fieldSubstitute(String aString, RowMetaInterface rowMeta, Object[] rowData)
void	fireJobFinishListeners() Sets the finished flag. Then launch all the job listeners and call the jobFinished method for each.
void	fireJobStartListeners() Call all the jobStarted method for each listener.
Map<JobEntryCopy,JobEntryJob>	getActiveJobEntryJobs() Gets the activeJobEntryJobs.
Map<JobEntryCopy,JobEntryTrans>	getActiveJobEntryTransformations() Gets the activeJobEntryTransformations.
String[]	getArguments()
long	getBatchId()
boolean	getBooleanValueOfVariable(String variableName, boolean defaultValue)
String	getContainerObjectId() Gets the carteObjectId.
Date	getCurrentDate()
List<DelegationListener>	getDelegationListeners()
Date	getDepDate() Gets the dep date.
Date	getEndDate()
int	getErrors() Get the number of errors that happened in the job.
String	getExecutingServer() Gets the executing server.
String	getExecutingUser() Gets the executing user.
Map<String,Object>	getExtensionDataMap()
String	getFilename() Gets the file name.
List<JobEntryListener>	getJobEntryListeners()
List<JobEntryResult>	getJobEntryResults() Gets a flat list of results in THIS job, in the order of execution of job entries.
List<JobListener>	getJobListeners()
JobMeta	getJobMeta()
String	getJobname()
JobTracker	getJobTracker()
LogChannelInterface	getLogChannel() Gets the log channel interface.
String	getLogChannelId() Gets the log channel id.
Date	getLogDate()
List<LoggingHierarchy>	getLoggingHierarchy() Gets the logging hierarchy.
LogLevel	getLogLevel() Gets the logLevel.
String	getObjectCopy() Always returns null for Job.
ObjectId	getObjectId() Gets the jobMeta's object id.
String	getObjectName() Gets the job name.
ObjectRevision	getObjectRevision() Gets the job meta's object revision.
LoggingObjectType	getObjectType() Gets LoggingObjectType.JOB, which is always the value for Job.
String	getParameterDefault(String key)
String	getParameterDescription(String key)
String	getParameterValue(String key)
LoggingObjectInterface	getParent() Gets parent logging object.
Job	getParentJob() Gets the parent job.
LoggingObjectInterface	getParentLoggingObject() Gets the parent logging object.
Trans	getParentTrans()
VariableSpace	getParentVariableSpace()
long	getPassedBatchId()
Date	getRegistrationDate() Gets the registration date.
Repository	getRep()
RepositoryDirectoryInterface	getRepositoryDirectory() Gets the job meta's repository directory interface.
Result	getResult()
SocketRepository	getSocketRepository() Gets the socket repository.
List<RowMetaAndData>	getSourceRows() Gets the source rows.
Date	getStartDate()
JobEntryCopy	getStartJobEntryCopy() Gets the start job entry copy.
Result	getStartJobEntryResult()
String	getStatus()
Thread	getThread()
String	getTransactionId() Gets the transaction id.
String	getVariable(String variableName)
String	getVariable(String variableName, String defaultValue)
void	init()
void	initializeVariablesFrom(VariableSpace parent)
void	injectVariables(Map<String,String> prop)
boolean	isActive()
boolean	isFinished()
boolean	isForcingSeparateLogging()
boolean	isGatheringMetrics()
boolean	isInitialized()
boolean	isInteractive() Gets the boolean value of interactive.
boolean	isStopped()
String[]	listParameters()
String[]	listVariables()
void	mergeParametersWith(NamedParams params, boolean replace)
void	removeJobEntryListener(JobEntryListener jobEntryListener)
void	removeJobListener(JobListener jobListener)
void	resetErrors() Set the number of occured errors to 0.
void	run() Threads main loop: called by Thread.start();
static String	sendToSlaveServer(JobMeta jobMeta, JobExecutionConfiguration executionConfiguration, Repository repository, org.pentaho.metastore.api.IMetaStore metaStore) Send to slave server.
protected void	setActive(boolean active)
void	setArguments(String[] arguments)
void	setBatchId(long batchId)
void	setContainerObjectId(String containerObjectId) Sets the execution container object id (containerObjectId).
void	setDelegationListeners(List<DelegationListener> delegationListeners)
void	setExecutingServer(String executingServer) Sets the executing server.
void	setExecutingUser(String executingUser) Sets the executing user.
void	setFinished(boolean finished)
void	setForcingSeparateLogging(boolean forcingSeparateLogging)
void	setGatheringMetrics(boolean gatheringMetrics)
protected void	setInitialized(boolean initialized)
void	setInteractive(boolean interactive) Sets the value of interactive.
protected void	setInternalEntryCurrentDirectory(boolean hasFilename, boolean hasRepoDir)
void	setInternalKettleVariables(VariableSpace var) Sets the internal kettle variables.
void	setJobTracker(JobTracker jobTracker)
void	setLogLevel(LogLevel logLevel) Sets the log level.
void	setParameterValue(String key, String value)
void	setParentJob(Job parentJob) Sets the parent job.
void	setParentTrans(Trans parentTrans)
void	setParentVariableSpace(VariableSpace parent)
void	setPassedBatchId(long jobBatchId)
void	setRepository(Repository rep)
void	setResult(Result result)
void	setSocketRepository(SocketRepository socketRepository) Sets the socket repository.
void	setSourceRows(List<RowMetaAndData> sourceRows)
void	setStartJobEntryCopy(JobEntryCopy startJobEntryCopy) Sets the start job entry copy.
void	setStartJobEntryResult(Result startJobEntryResult)
void	setStopped(boolean stopped) Sets the stopped.
void	setTransactionId(String transactionId) Sets the transaction id.
void	setVariable(String variableName, String variableValue)
void	shareVariablesWith(VariableSpace space)
protected void	shutdownHeartbeat(ExecutorService heartbeat)
protected ExecutorService	startHeartbeat(long intervalInSeconds)
void	stopAll() Stop all activity by setting the stopped property to true.
String	toString() Gets the name property of the JobMeta property.
void	waitUntilFinished() Wait until this job has finished.
void	waitUntilFinished(long maxMiliseconds) Wait until this job has finished.
protected void	writeJobEntryLogInformation() Write job entry log information.
protected void	writeLogChannelInformation() Write log channel information.
protected void	writeLogTableInformation(JobLogTable jobLogTable, LogStatus status) Writes information to Job Log table.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, yield

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.pentaho.di.core.variables.VariableSpace

environmentSubstitute

Field Detail

CONFIGURATION_IN_EXPORT_FILENAME

public static final String CONFIGURATION_IN_EXPORT_FILENAME

See Also:

Constant Field Values

parentJob

protected Job parentJob

The job that's launching this (sub-) job. This gives us access to the whole chain, including the parent variables, etc.

parentTrans

protected Trans parentTrans

The parent transformation

arguments

protected String[] arguments

The command line arguments for the job.

Constructor Detail

Job

public Job(String name,
           String file,
           String[] args)

Job

public Job(Repository repository,
           JobMeta jobMeta)

Job

public Job(Repository repository,
           JobMeta jobMeta,
           LoggingObjectInterface parentLogging)

Job

public Job()

Method Detail

init

public void init()

toString

public String toString()

Gets the name property of the JobMeta property.

Overrides:

toString in class Thread

Returns:

String name for the JobMeta

createJobWithNewClassLoader

public static final Job createJobWithNewClassLoader()
                                             throws KettleException

Throws:

KettleException

getJobname

public String getJobname()

setRepository

public void setRepository(Repository rep)

run

public void run()

Threads main loop: called by Thread.start();

Specified by:

run in interface Runnable

Overrides:

run in class Thread

execute

public Result execute(int nr,
                      Result result)
               throws KettleException

Execute a job with previous results passed in.

Execute called by JobEntryJob: don't clear the jobEntryResults.

Parameters:

nr - The job entry number

result - the result of the previous execution

Returns:

Result of the job execution

Throws:

KettleJobException

KettleException

fireJobFinishListeners

public void fireJobFinishListeners()
                            throws KettleException

Sets the finished flag. Then launch all the job listeners and call the jobFinished method for each.

Throws:

KettleException

See Also:

JobListener.jobFinished(Job)

fireJobStartListeners

public void fireJobStartListeners()
                           throws KettleException

Call all the jobStarted method for each listener.

Throws:

KettleException

See Also:

JobListener.jobStarted(Job)

waitUntilFinished

public void waitUntilFinished()

Wait until this job has finished.

waitUntilFinished

public void waitUntilFinished(long maxMiliseconds)

Wait until this job has finished.

Parameters:

maxMiliseconds - the maximum number of ms to wait

getErrors

public int getErrors()

Get the number of errors that happened in the job.

Returns:

nr of error that have occurred during execution. During execution of a job the number can change.

resetErrors

public void resetErrors()

Set the number of occured errors to 0.

addErrors

public void addErrors(int nrToAdd)

Add a number of errors to the total number of erros that occured during execution.

Parameters:

nrToAdd - nr of errors to add.

beginProcessing

public boolean beginProcessing()
                        throws KettleException

Handle logging at start

Returns:

true if it went OK.

Throws:

KettleException

writeLogTableInformation

protected void writeLogTableInformation(JobLogTable jobLogTable,
                                        LogStatus status)
                                 throws KettleJobException,
                                        KettleDatabaseException

Writes information to Job Log table. Cleans old records, in case job is finished.

Throws:

KettleJobException

KettleDatabaseException

writeLogChannelInformation

protected void writeLogChannelInformation()
                                   throws KettleException

Write log channel information.

Throws:

KettleException - the kettle exception

writeJobEntryLogInformation

protected void writeJobEntryLogInformation()
                                    throws KettleException

Write job entry log information.

Throws:

KettleException - the kettle exception

createDataBase

protected Database createDataBase(DatabaseMeta databaseMeta)

isInitialized

public boolean isInitialized()

setInitialized

protected void setInitialized(boolean initialized)

isActive

public boolean isActive()

setActive

protected void setActive(boolean active)

isStopped

public boolean isStopped()

stopAll

public void stopAll()

Stop all activity by setting the stopped property to true.

setStopped

public void setStopped(boolean stopped)

Sets the stopped.

isFinished

public boolean isFinished()

setFinished

public void setFinished(boolean finished)

getStartDate

public Date getStartDate()

getEndDate

public Date getEndDate()

getCurrentDate

public Date getCurrentDate()

getDepDate

public Date getDepDate()

Gets the dep date.

Returns:

Returns the depDate

getLogDate

public Date getLogDate()

getJobMeta

public JobMeta getJobMeta()

getRep

public Repository getRep()

getThread

public Thread getThread()

getJobTracker

public JobTracker getJobTracker()

setJobTracker

public void setJobTracker(JobTracker jobTracker)

setSourceRows

public void setSourceRows(List<RowMetaAndData> sourceRows)

getSourceRows

public List<RowMetaAndData> getSourceRows()

Gets the source rows.

Returns:

the source rows

getParentJob

public Job getParentJob()

Gets the parent job.

Returns:

Returns the parentJob

setParentJob

public void setParentJob(Job parentJob)

Sets the parent job.

Parameters:

parentJob - The parentJob to set.

getResult

public Result getResult()

setResult

public void setResult(Result result)

getBatchId

public long getBatchId()

setBatchId

public void setBatchId(long batchId)

getPassedBatchId

public long getPassedBatchId()

setPassedBatchId

public void setPassedBatchId(long jobBatchId)

setInternalKettleVariables

public void setInternalKettleVariables(VariableSpace var)

Sets the internal kettle variables.

Parameters:

var - the new internal kettle variables.

setInternalEntryCurrentDirectory

protected void setInternalEntryCurrentDirectory(boolean hasFilename,
                                                boolean hasRepoDir)

copyVariablesFrom

public void copyVariablesFrom(VariableSpace space)

Specified by:

copyVariablesFrom in interface VariableSpace

environmentSubstitute

public String environmentSubstitute(String aString)

Specified by:

environmentSubstitute in interface VariableSpace

environmentSubstitute

public String[] environmentSubstitute(String[] aString)

Specified by:

environmentSubstitute in interface VariableSpace

fieldSubstitute

public String fieldSubstitute(String aString,
                              RowMetaInterface rowMeta,
                              Object[] rowData)
                       throws KettleValueException

Specified by:

fieldSubstitute in interface VariableSpace

Throws:

KettleValueException

getParentVariableSpace

public VariableSpace getParentVariableSpace()

Specified by:

getParentVariableSpace in interface VariableSpace

setParentVariableSpace

public void setParentVariableSpace(VariableSpace parent)

Specified by:

setParentVariableSpace in interface VariableSpace

getVariable

public String getVariable(String variableName,
                          String defaultValue)

Specified by:

getVariable in interface VariableSpace

getVariable

public String getVariable(String variableName)

Specified by:

getVariable in interface VariableSpace

getBooleanValueOfVariable

public boolean getBooleanValueOfVariable(String variableName,
                                         boolean defaultValue)

Specified by:

getBooleanValueOfVariable in interface VariableSpace

initializeVariablesFrom

public void initializeVariablesFrom(VariableSpace parent)

Specified by:

initializeVariablesFrom in interface VariableSpace

listVariables

public String[] listVariables()

Specified by:

listVariables in interface VariableSpace

setVariable

public void setVariable(String variableName,
                        String variableValue)

Specified by:

setVariable in interface VariableSpace

shareVariablesWith

public void shareVariablesWith(VariableSpace space)

Specified by:

shareVariablesWith in interface VariableSpace

injectVariables

public void injectVariables(Map<String,String> prop)

Specified by:

injectVariables in interface VariableSpace

getStatus

public String getStatus()

sendToSlaveServer

public static String sendToSlaveServer(JobMeta jobMeta,
                                       JobExecutionConfiguration executionConfiguration,
                                       Repository repository,
                                       org.pentaho.metastore.api.IMetaStore metaStore)
                                throws KettleException

Send to slave server.

Parameters:

jobMeta - the job meta

executionConfiguration - the execution configuration

repository - the repository

metaStore - the metaStore

Returns:

the string

Throws:

KettleException - the kettle exception

addJobListener

public void addJobListener(JobListener jobListener)

addJobEntryListener

public void addJobEntryListener(JobEntryListener jobEntryListener)

removeJobListener

public void removeJobListener(JobListener jobListener)

removeJobEntryListener

public void removeJobEntryListener(JobEntryListener jobEntryListener)

getJobEntryListeners

public List<JobEntryListener> getJobEntryListeners()

getJobListeners

public List<JobListener> getJobListeners()

addParameterDefinition

public void addParameterDefinition(String key,
                                   String defValue,
                                   String description)
                            throws DuplicateParamException

Specified by:

addParameterDefinition in interface NamedParams

Throws:

DuplicateParamException

getParameterDescription

public String getParameterDescription(String key)
                               throws UnknownParamException

Specified by:

getParameterDescription in interface NamedParams

Throws:

UnknownParamException

getParameterDefault

public String getParameterDefault(String key)
                           throws UnknownParamException

Specified by:

getParameterDefault in interface NamedParams

Throws:

UnknownParamException

getParameterValue

public String getParameterValue(String key)
                         throws UnknownParamException

Specified by:

getParameterValue in interface NamedParams

Throws:

UnknownParamException

listParameters

public String[] listParameters()

Specified by:

listParameters in interface NamedParams

setParameterValue

public void setParameterValue(String key,
                              String value)
                       throws UnknownParamException

Specified by:

setParameterValue in interface NamedParams

Throws:

UnknownParamException

eraseParameters

public void eraseParameters()

Specified by:

eraseParameters in interface NamedParams

clearParameters

public void clearParameters()

Specified by:

clearParameters in interface NamedParams

activateParameters

public void activateParameters()

Specified by:

activateParameters in interface NamedParams

copyParametersFrom

public void copyParametersFrom(NamedParams params)

Specified by:

copyParametersFrom in interface NamedParams

mergeParametersWith

public void mergeParametersWith(NamedParams params,
                                boolean replace)

Specified by:

mergeParametersWith in interface NamedParams

setSocketRepository

public void setSocketRepository(SocketRepository socketRepository)

Sets the socket repository.

Parameters:

socketRepository - the new socket repository

getSocketRepository

public SocketRepository getSocketRepository()

Gets the socket repository.

Returns:

the socket repository

getLogChannel

public LogChannelInterface getLogChannel()

Gets the log channel interface.

Specified by:

getLogChannel in interface HasLogChannelInterface

Returns:

LogChannelInterface

getObjectName

public String getObjectName()

Gets the job name.

Specified by:

getObjectName in interface LoggingObjectInterface

Returns:

jobName

getObjectCopy

public String getObjectCopy()

Always returns null for Job.

Specified by:

getObjectCopy in interface LoggingObjectInterface

Returns:

null

getFilename

public String getFilename()

Gets the file name.

Specified by:

getFilename in interface LoggingObjectInterface

Returns:

the filename

getLogChannelId

public String getLogChannelId()

Gets the log channel id.

Specified by:

getLogChannelId in interface LoggingObjectInterface

Returns:

the logChannelId

getObjectId

public ObjectId getObjectId()

Gets the jobMeta's object id.

Specified by:

getObjectId in interface LoggingObjectInterface

Returns:

ObjectId

getObjectRevision

public ObjectRevision getObjectRevision()

Gets the job meta's object revision.

Specified by:

getObjectRevision in interface LoggingObjectInterface

Returns:

ObjectRevision

getObjectType

public LoggingObjectType getObjectType()

Gets LoggingObjectType.JOB, which is always the value for Job.

Specified by:

getObjectType in interface LoggingObjectInterface

Returns:

LoggingObjectType LoggingObjectType.JOB

getParent

public LoggingObjectInterface getParent()

Gets parent logging object.

Specified by:

getParent in interface LoggingObjectInterface

Returns:

parentLoggingObject

getRepositoryDirectory

public RepositoryDirectoryInterface getRepositoryDirectory()

Gets the job meta's repository directory interface.

Specified by:

getRepositoryDirectory in interface LoggingObjectInterface

Returns:

RepositoryDirectoryInterface

getLogLevel

public LogLevel getLogLevel()

Gets the logLevel.

Specified by:

getLogLevel in interface LoggingObjectInterface

Returns:

logLevel

setLogLevel

public void setLogLevel(LogLevel logLevel)

Sets the log level.

Parameters:

logLevel - the new log level

getLoggingHierarchy

public List<LoggingHierarchy> getLoggingHierarchy()

Gets the logging hierarchy.

Returns:

the logging hierarchy

isInteractive

public boolean isInteractive()

Gets the boolean value of interactive.

Returns:

the interactive

setInteractive

public void setInteractive(boolean interactive)

Sets the value of interactive.

Parameters:

interactive - the interactive to set

getActiveJobEntryTransformations

public Map<JobEntryCopy,JobEntryTrans> getActiveJobEntryTransformations()

Gets the activeJobEntryTransformations.

Returns:

the activeJobEntryTransformations

getActiveJobEntryJobs

public Map<JobEntryCopy,JobEntryJob> getActiveJobEntryJobs()

Gets the activeJobEntryJobs.

Returns:

the activeJobEntryJobs

getJobEntryResults

public List<JobEntryResult> getJobEntryResults()

Gets a flat list of results in THIS job, in the order of execution of job entries.

Returns:

A flat list of results in THIS job, in the order of execution of job entries

getContainerObjectId

public String getContainerObjectId()

Gets the carteObjectId.

Specified by:

getContainerObjectId in interface LoggingObjectInterface

Returns:

the carteObjectId

setContainerObjectId

public void setContainerObjectId(String containerObjectId)

Sets the execution container object id (containerObjectId).

Parameters:

containerObjectId - the execution container object id to set

getParentLoggingObject

public LoggingObjectInterface getParentLoggingObject()

Gets the parent logging object.

Returns:

the parent logging object

getRegistrationDate

public Date getRegistrationDate()

Gets the registration date. For job, this always returns null

Specified by:

getRegistrationDate in interface LoggingObjectInterface

Returns:

null

getStartJobEntryCopy

public JobEntryCopy getStartJobEntryCopy()

Gets the start job entry copy.

Returns:

the startJobEntryCopy

setStartJobEntryCopy

public void setStartJobEntryCopy(JobEntryCopy startJobEntryCopy)

Sets the start job entry copy.

Parameters:

startJobEntryCopy - the startJobEntryCopy to set

getExecutingServer

public String getExecutingServer()

Gets the executing server.

Specified by:

getExecutingServer in interface ExecutorInterface

Returns:

the executingServer

setExecutingServer

public void setExecutingServer(String executingServer)

Sets the executing server.

Specified by:

setExecutingServer in interface ExecutorInterface

Parameters:

executingServer - the executingServer to set

getExecutingUser

public String getExecutingUser()

Gets the executing user.

Specified by:

getExecutingUser in interface ExecutorInterface

Returns:

the executingUser

setExecutingUser

public void setExecutingUser(String executingUser)

Sets the executing user.

Specified by:

setExecutingUser in interface ExecutorInterface

Parameters:

executingUser - the executingUser to set

isGatheringMetrics

public boolean isGatheringMetrics()

Specified by:

isGatheringMetrics in interface LoggingObjectInterface

setGatheringMetrics

public void setGatheringMetrics(boolean gatheringMetrics)

Specified by:

setGatheringMetrics in interface LoggingObjectInterface

isForcingSeparateLogging

public boolean isForcingSeparateLogging()

Specified by:

isForcingSeparateLogging in interface LoggingObjectInterface

setForcingSeparateLogging

public void setForcingSeparateLogging(boolean forcingSeparateLogging)

Specified by:

setForcingSeparateLogging in interface LoggingObjectInterface

getTransactionId

public String getTransactionId()

Gets the transaction id.

Returns:

the transactionId

setTransactionId

public void setTransactionId(String transactionId)

Sets the transaction id.

Parameters:

transactionId - the transactionId to set

getDelegationListeners

public List<DelegationListener> getDelegationListeners()

setDelegationListeners

public void setDelegationListeners(List<DelegationListener> delegationListeners)

addDelegationListener

public void addDelegationListener(DelegationListener delegationListener)

getArguments

public String[] getArguments()

setArguments

public void setArguments(String[] arguments)

getParentTrans

public Trans getParentTrans()

setParentTrans

public void setParentTrans(Trans parentTrans)

getExtensionDataMap

public Map<String,Object> getExtensionDataMap()

Specified by:

getExtensionDataMap in interface ExtensionDataInterface

getStartJobEntryResult

public Result getStartJobEntryResult()

setStartJobEntryResult

public void setStartJobEntryResult(Result startJobEntryResult)

startHeartbeat

protected ExecutorService startHeartbeat(long intervalInSeconds)

shutdownHeartbeat

protected void shutdownHeartbeat(ExecutorService heartbeat)