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() Empty constructor, for Class.newInstance()
Job(Repository repository, JobMeta jobMeta) Instantiates a new job.
Job(Repository repository, JobMeta jobMeta, LoggingObjectInterface parentLogging) Instantiates a new job.
Job(String name, String file, String[] args) Instantiates a new job.

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) Adds the job entry listener.
void	addJobListener(JobListener jobListener) Add a job listener to the job
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() Creates the job with new class loader.
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() Gets the batchId.
boolean	getBooleanValueOfVariable(String variableName, boolean defaultValue)
String	getContainerObjectId() Gets the carteObjectId.
Date	getCurrentDate() Gets the current date.
List<DelegationListener>	getDelegationListeners()
Date	getDepDate() Gets the dep date.
Date	getEndDate() Gets the end date.
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() Gets the job entry listeners.
List<JobEntryResult>	getJobEntryResults() Gets a flat list of results in THIS job, in the order of execution of job entries.
List<JobListener>	getJobListeners() Gets the job listeners.
JobMeta	getJobMeta() Gets the job meta.
String	getJobname() Gets the jobname.
JobTracker	getJobTracker() Gets the job tracker.
LogChannelInterface	getLogChannel() Gets the log channel interface.
String	getLogChannelId() Gets the log channel id.
Date	getLogDate() Gets the log date.
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() Gets the passedBatchId.
Date	getRegistrationDate() Gets the registration date.
Repository	getRep() Gets the rep (repository).
RepositoryDirectoryInterface	getRepositoryDirectory() Gets the job meta's repository directory interface.
Result	getResult() Gets the result.
SocketRepository	getSocketRepository() Gets the socket repository.
List<RowMetaAndData>	getSourceRows() Gets the source rows.
Date	getStartDate() Gets the start date.
JobEntryCopy	getStartJobEntryCopy() Gets the start job entry copy.
Result	getStartJobEntryResult()
String	getStatus() Gets the status.
Thread	getThread() Gets the thread.
String	getTransactionId() Gets the transaction id.
String	getVariable(String variableName)
String	getVariable(String variableName, String defaultValue)
void	init() Initializes the Job.
void	initializeVariablesFrom(VariableSpace parent)
void	injectVariables(Map<String,String> prop)
boolean	isActive() Checks if is active.
boolean	isFinished() Gets the boolean value of finished.
boolean	isForcingSeparateLogging()
boolean	isGatheringMetrics()
boolean	isInitialized() Gets the boolean value of initialized.
boolean	isInteractive() Gets the boolean value of interactive.
boolean	isStopped() Gets the stopped status of this Job.
String[]	listParameters()
String[]	listVariables()
void	removeJobEntryListener(JobEntryListener jobEntryListener) Remove a job entry listener from the job
void	removeJobListener(JobListener jobListener) Remove a job listener from the job
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.
void	setArguments(String[] arguments)
void	setBatchId(long batchId) Sets the 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) Sets the value of finished.
void	setForcingSeparateLogging(boolean forcingSeparateLogging)
void	setGatheringMetrics(boolean gatheringMetrics)
void	setInteractive(boolean interactive) Sets the value of interactive.
void	setInternalKettleVariables(VariableSpace var) Sets the internal kettle variables.
void	setJobTracker(JobTracker jobTracker) Sets the job tracker.
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) Sets the passedBatchId.
void	setRepository(Repository rep) Sets the repository.
void	setResult(Result result) Sets the result.
void	setSocketRepository(SocketRepository socketRepository) Sets the socket repository.
void	setSourceRows(List<RowMetaAndData> sourceRows) Sets the source rows.
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

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)

Instantiates a new job.

Parameters:

name - the name

file - the file

args - the args

Job

public Job(Repository repository,
           JobMeta jobMeta)

Instantiates a new job.

Parameters:

repository - the repository

jobMeta - the job meta

Job

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

Instantiates a new job.

Parameters:

repository - the repository

jobMeta - the job meta

parentLogging - the parent logging

Job

public Job()

Empty constructor, for Class.newInstance()

Method Detail

init

public void init()

Initializes the Job.

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

Creates the job with new class loader.

Returns:

the job

Throws:

KettleException - the kettle exception

getJobname

public String getJobname()

Gets the jobname.

Returns:

the jobname

setRepository

public void setRepository(Repository rep)

Sets the repository.

Parameters:

rep - the new repository

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)

isActive

public boolean isActive()

Checks if is active.

Returns:

true, if is active

stopAll

public void stopAll()

Stop all activity by setting the stopped property to true.

setStopped

public void setStopped(boolean stopped)

Sets the stopped.

Parameters:

stopped - the new stopped

isStopped

public boolean isStopped()

Gets the stopped status of this Job.

Returns:

Returns the stopped status of this Job

getStartDate

public Date getStartDate()

Gets the start date.

Returns:

Returns the startDate

getEndDate

public Date getEndDate()

Gets the end date.

Returns:

Returns the endDate

getCurrentDate

public Date getCurrentDate()

Gets the current date.

Returns:

Returns the currentDate

getDepDate

public Date getDepDate()

Gets the dep date.

Returns:

Returns the depDate

getLogDate

public Date getLogDate()

Gets the log date.

Returns:

Returns the logDate

getJobMeta

public JobMeta getJobMeta()

Gets the job meta.

Returns:

Returns the JobMeta

getRep

public Repository getRep()

Gets the rep (repository).

Returns:

Returns the rep

getThread

public Thread getThread()

Gets the thread.

Returns:

the thread

getJobTracker

public JobTracker getJobTracker()

Gets the job tracker.

Returns:

Returns the jobTracker

setJobTracker

public void setJobTracker(JobTracker jobTracker)

Sets the job tracker.

Parameters:

jobTracker - The jobTracker to set

setSourceRows

public void setSourceRows(List<RowMetaAndData> sourceRows)

Sets the source rows.

Parameters:

sourceRows - the new source rows

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()

Gets the result.

Returns:

the result

setResult

public void setResult(Result result)

Sets the result.

Parameters:

result - the new result

isInitialized

public boolean isInitialized()

Gets the boolean value of initialized.

Returns:

Returns the initialized

getBatchId

public long getBatchId()

Gets the batchId.

Returns:

Returns the batchId

setBatchId

public void setBatchId(long batchId)

Sets the batchId.

Parameters:

batchId - The batchId to set

getPassedBatchId

public long getPassedBatchId()

Gets the passedBatchId.

Returns:

the passedBatchId

setPassedBatchId

public void setPassedBatchId(long jobBatchId)

Sets the passedBatchId.

Parameters:

jobBatchId - the jobBatchId to set

setInternalKettleVariables

public void setInternalKettleVariables(VariableSpace var)

Sets the internal kettle variables.

Parameters:

var - the new internal kettle variables.

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()

Gets the status.

Returns:

the status

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)

Add a job listener to the job

Parameters:

jobListener - the job listener to add

addJobEntryListener

public void addJobEntryListener(JobEntryListener jobEntryListener)

Adds the job entry listener.

Parameters:

jobEntryListener - the job entry listener

removeJobListener

public void removeJobListener(JobListener jobListener)

Remove a job listener from the job

Parameters:

jobListener - the job listener to remove

removeJobEntryListener

public void removeJobEntryListener(JobEntryListener jobEntryListener)

Remove a job entry listener from the job

Parameters:

jobListener - the job entry listener to remove

getJobEntryListeners

public List<JobEntryListener> getJobEntryListeners()

Gets the job entry listeners.

Returns:

the job entry listeners

getJobListeners

public List<JobListener> getJobListeners()

Gets the job listeners.

Returns:

the job listeners

isFinished

public boolean isFinished()

Gets the boolean value of finished.

Returns:

the finished

setFinished

public void setFinished(boolean finished)

Sets the value of finished.

Parameters:

finished - the finished to set

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

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)