org.pentaho.di.job
Class Job

java.lang.Object
  extended by java.lang.Thread
      extended by org.pentaho.di.job.Job
All Implemented Interfaces:
Runnable, HasLogChannelInterface, LoggingObjectInterface, NamedParams, VariableSpace

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

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
static String CONFIGURATION_IN_EXPORT_FILENAME
           
 
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
 
Constructor Summary
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
 void activateParameters()
          Activate the currently set parameters
 void addErrors(int nrToAdd)
          Add a number of errors to the total number of errors that occurred 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)
          Add a parameter definition to this set.
 boolean beginProcessing()
          Handle logging at start.
 void clearParameters()
          Clear all parameters
 void copyParametersFrom(NamedParams params)
          Copy params to these named parameters (clearing out first).
 void copyVariablesFrom(VariableSpace space)
          Copy the variables from another space, without initializing with the defaults.
static Job createJobWithNewClassLoader()
          Creates the job with new class loader.
 String environmentSubstitute(String aString)
          Substitute the string using the current variable space.
 String[] environmentSubstitute(String[] aString)
          Replaces environment variables in an array of strings.
 void eraseParameters()
          Clear the values.
 Result execute(int nr, Result result)
          Execute a job with previous results passed in.

Execute called by JobEntryJob: don't clear the jobEntryResults.
 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 active job entry jobs.
 Map<JobEntryCopy,JobEntryTrans> getActiveJobEntryTransformations()
          Gets the active job entry transformations.
 long getBatchId()
          Gets the batch id.
 boolean getBooleanValueOfVariable(String variableName, boolean defaultValue)
          This method returns a boolean for the new variable check boxes.
 String getContainerObjectId()
          Gets the carte object id.
 Date getCurrentDate()
          Gets the current date.
 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 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 job name.
 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 log level.
 String getObjectCopy()
          Always returns null for Job.
 ObjectId getObjectId()
          Gets the job meta'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)
          Get the default value of a parameter.
 String getParameterDescription(String key)
          Get the description of a parameter.
 String getParameterValue(String key)
          Get the value of a parameter.
 LoggingObjectInterface getParent()
          Gets parent logging object.
 Job getParentJob()
          Gets the parent job.
 LoggingObjectInterface getParentLoggingObject()
          Gets the parent logging object.
 VariableSpace getParentVariableSpace()
          Get the parent of the variable space.
 long getPassedBatchId()
          Gets the passed batch id.
 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.
 String getStatus()
          Gets the status.
 Thread getThread()
          Gets the thread.
 String getVariable(String variableName)
          Get the value of a variable.
 String getVariable(String variableName, String defaultValue)
          Get the value of a variable with a default in case the variable is not found.
 void init()
          Initializes the Job.
 void initializeVariablesFrom(VariableSpace parent)
          Initialize variable space using the defaults, copy over the variables from the parent (using copyVariablesFrom()), after this the "injected" variables should be inserted (injectVariables()).
 void injectVariables(Map<String,String> prop)
          Inject variables.
 boolean isActive()
          Checks if is active.
 boolean isFinished()
          Gets the boolean value of finished.
 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()
          List the parameters.
 String[] listVariables()
          List the variables (not the values) that are currently in the variable space.
 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)
          Send to slave server.
 void setBatchId(long batchId)
          Sets the batch id.
 void setContainerObjectId(String containerObjectId)
          Sets the execution container object id (containerObjectId).
 void setFinished(boolean finished)
          Sets the value of finished.
 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)
          Set the value of a parameter.
 void setParentJob(Job parentJob)
          Sets the parent job.
 void setParentVariableSpace(VariableSpace parent)
          Set the parent variable space
 void setPassedBatchId(long jobBatchId)
          Sets the passed batch id.
 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 setStopped(boolean stopped)
          Sets the stopped.
 void setVariable(String variableName, String variableValue)
          Sets a variable in the Kettle Variables list.
 void shareVariablesWith(VariableSpace space)
          Share a variable space from another variable space.
 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.
 
Methods inherited from class java.lang.Thread
activeCount, checkAccess, 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, 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
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 job name.

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 errors that occurred 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

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:
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 batch id.

Returns:
Returns the batchId

setBatchId

public void setBatchId(long batchId)
Sets the batch id.

Parameters:
batchId - The batchId to set

getPassedBatchId

public long getPassedBatchId()
Gets the passed batch id.

Returns:
the passedBatchId

setPassedBatchId

public void setPassedBatchId(long jobBatchId)
Sets the passed batch id.

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)
Description copied from interface: VariableSpace
Copy the variables from another space, without initializing with the defaults. This does not affect any parent relationship.

Specified by:
copyVariablesFrom in interface VariableSpace
Parameters:
space - the space to copy the variables from.

environmentSubstitute

public String environmentSubstitute(String aString)
Description copied from interface: VariableSpace
Substitute the string using the current variable space.

Specified by:
environmentSubstitute in interface VariableSpace
Parameters:
aString - The string to substitute.
Returns:
The substituted string.

environmentSubstitute

public String[] environmentSubstitute(String[] aString)
Description copied from interface: VariableSpace
Replaces environment variables in an array of strings. See also: environmentSubstitute(String string)

Specified by:
environmentSubstitute in interface VariableSpace
Parameters:
aString - The array of strings that wants its variables to be replaced.
Returns:
the array with the environment variables replaced.

getParentVariableSpace

public VariableSpace getParentVariableSpace()
Description copied from interface: VariableSpace
Get the parent of the variable space.

Specified by:
getParentVariableSpace in interface VariableSpace
Returns:
the parent.

setParentVariableSpace

public void setParentVariableSpace(VariableSpace parent)
Description copied from interface: VariableSpace
Set the parent variable space

Specified by:
setParentVariableSpace in interface VariableSpace
Parameters:
parent - The parent variable space to set

getVariable

public String getVariable(String variableName,
                          String defaultValue)
Description copied from interface: VariableSpace
Get the value of a variable with a default in case the variable is not found.

Specified by:
getVariable in interface VariableSpace
Parameters:
variableName - The name of the variable
defaultValue - The default value in case the variable could not be found
Returns:
the String value of a variable

getVariable

public String getVariable(String variableName)
Description copied from interface: VariableSpace
Get the value of a variable.

Specified by:
getVariable in interface VariableSpace
Parameters:
variableName - The name of the variable
Returns:
the String value of a variable or null in case the variable could not be found.

getBooleanValueOfVariable

public boolean getBooleanValueOfVariable(String variableName,
                                         boolean defaultValue)
Description copied from interface: VariableSpace
This method returns a boolean for the new variable check boxes. If the variable name is not set or the variable name is not specified, this method simply returns the default value. If not, it convert the variable value to a boolean. "Y", "YES" and "TRUE" all convert to true. (case insensitive)

Specified by:
getBooleanValueOfVariable in interface VariableSpace
Parameters:
variableName - The variable to look up.
defaultValue - The default value to return.
Returns:
See Also:
static method ValueMeta.convertStringToBoolean()

initializeVariablesFrom

public void initializeVariablesFrom(VariableSpace parent)
Description copied from interface: VariableSpace
Initialize variable space using the defaults, copy over the variables from the parent (using copyVariablesFrom()), after this the "injected" variables should be inserted (injectVariables()). The parent is set as parent variable space.

Specified by:
initializeVariablesFrom in interface VariableSpace
Parameters:
parent - the parent to start from, or null if root.

listVariables

public String[] listVariables()
Description copied from interface: VariableSpace
List the variables (not the values) that are currently in the variable space.

Specified by:
listVariables in interface VariableSpace
Returns:
Array of String variable names.

setVariable

public void setVariable(String variableName,
                        String variableValue)
Description copied from interface: VariableSpace
Sets a variable in the Kettle Variables list.

Specified by:
setVariable in interface VariableSpace
Parameters:
variableName - The name of the variable to set
variableValue - The value of the variable to set. If the variableValue is null, the variable is cleared from the list.

shareVariablesWith

public void shareVariablesWith(VariableSpace space)
Description copied from interface: VariableSpace
Share a variable space from another variable space. This means that the object should take over the space used as argument.

Specified by:
shareVariablesWith in interface VariableSpace
Parameters:
space - Variable space to be shared.

injectVariables

public void injectVariables(Map<String,String> prop)
Description copied from interface: VariableSpace
Inject variables. The behaviour should be that the properties object will be stored and at the time the VariableSpace is initialized (or upon calling this method if the space is already initialized). After injecting the link of the properties object should be removed.

Specified by:
injectVariables in interface VariableSpace
Parameters:
prop - Properties object containing key-value pairs.

getStatus

public String getStatus()
Gets the status.

Returns:
the status

sendToSlaveServer

public static String sendToSlaveServer(JobMeta jobMeta,
                                       JobExecutionConfiguration executionConfiguration,
                                       Repository repository)
                                throws KettleException
Send to slave server.

Parameters:
jobMeta - the job meta
executionConfiguration - the execution configuration
repository - the repository
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
Description copied from interface: NamedParams
Add a parameter definition to this set. TODO: default, throw exception

Specified by:
addParameterDefinition in interface NamedParams
Parameters:
key - Name of the parameter.
defValue - default value.
description - Description of the parameter.
Throws:
DuplicateParamException - Upon duplicate parameter definitions

getParameterDescription

public String getParameterDescription(String key)
                               throws UnknownParamException
Description copied from interface: NamedParams
Get the description of a parameter.

Specified by:
getParameterDescription in interface NamedParams
Parameters:
key - Key to get value for.
Returns:
description of parameter key.
Throws:
UnknownParamException - Parameter 'key' is unknown.

getParameterDefault

public String getParameterDefault(String key)
                           throws UnknownParamException
Description copied from interface: NamedParams
Get the default value of a parameter.

Specified by:
getParameterDefault in interface NamedParams
Parameters:
key - Key to get value for.
Returns:
default value for parameter key.
Throws:
UnknownParamException - Parameter 'key' is unknown.

getParameterValue

public String getParameterValue(String key)
                         throws UnknownParamException
Description copied from interface: NamedParams
Get the value of a parameter.

Specified by:
getParameterValue in interface NamedParams
Parameters:
key - Key to get value for.
Returns:
value of parameter key.
Throws:
UnknownParamException - Parameter 'key' is unknown.

listParameters

public String[] listParameters()
Description copied from interface: NamedParams
List the parameters.

Specified by:
listParameters in interface NamedParams
Returns:
Array of parameters.

setParameterValue

public void setParameterValue(String key,
                              String value)
                       throws UnknownParamException
Description copied from interface: NamedParams
Set the value of a parameter.

Specified by:
setParameterValue in interface NamedParams
Parameters:
key - key to set value of
value - value to set it to.
Throws:
UnknownParamException - Parameter 'key' is unknown.

eraseParameters

public void eraseParameters()
Description copied from interface: NamedParams
Clear the values.

Specified by:
eraseParameters in interface NamedParams

clearParameters

public void clearParameters()
Description copied from interface: NamedParams
Clear all parameters

Specified by:
clearParameters in interface NamedParams

activateParameters

public void activateParameters()
Description copied from interface: NamedParams
Activate the currently set parameters

Specified by:
activateParameters in interface NamedParams

copyParametersFrom

public void copyParametersFrom(NamedParams params)
Description copied from interface: NamedParams
Copy params to these named parameters (clearing out first).

Specified by:
copyParametersFrom in interface NamedParams
Parameters:
params - the parameters to copy from.

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 job meta'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 log level.

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 active job entry transformations.

Returns:
the activeJobEntryTransformations

getActiveJobEntryJobs

public Map<JobEntryCopy,JobEntryJob> getActiveJobEntryJobs()
Gets the active job entry jobs.

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 carte object id.

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