org.pentaho.di.job

Class Job

java.lang.Object

java.lang.Thread

org.pentaho.di.job.Job

All Implemented Interfaces:

Runnable, ExecutorInterface, org.pentaho.di.core.ExtensionDataInterface, HasLogChannelInterface, org.pentaho.di.core.logging.LoggingObjectInterface, org.pentaho.di.core.parameters.NamedParams, org.pentaho.di.core.variables.VariableSpace

public class Job
extends Thread
implements org.pentaho.di.core.variables.VariableSpace, org.pentaho.di.core.parameters.NamedParams, HasLogChannelInterface, org.pentaho.di.core.logging.LoggingObjectInterface, ExecutorInterface, org.pentaho.di.core.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
static String	CONFIGURATION_IN_EXPORT_FILENAME

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, org.pentaho.di.core.logging.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(org.pentaho.di.core.parameters.NamedParams params)
void	copyVariablesFrom(org.pentaho.di.core.variables.VariableSpace space)
static Job	createJobWithNewClassLoader() Creates the job with new class loader.
String	environmentSubstitute(String aString)
String[]	environmentSubstitute(String[] aString)
void	eraseParameters()
org.pentaho.di.core.Result	execute(int nr, org.pentaho.di.core.Result result) Execute a job with previous results passed in. Execute called by JobEntryJob: don't clear the jobEntryResults.
String	fieldSubstitute(String aString, org.pentaho.di.core.row.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.
org.pentaho.di.core.logging.LogChannelInterface	getLogChannel() Gets the log channel interface.
String	getLogChannelId() Gets the log channel id.
Date	getLogDate() Gets the log date.
List<org.pentaho.di.core.logging.LoggingHierarchy>	getLoggingHierarchy() Gets the logging hierarchy.
org.pentaho.di.core.logging.LogLevel	getLogLevel() Gets the logLevel.
String	getObjectCopy() Always returns null for Job.
org.pentaho.di.repository.ObjectId	getObjectId() Gets the jobMeta's object id.
String	getObjectName() Gets the job name.
org.pentaho.di.repository.ObjectRevision	getObjectRevision() Gets the job meta's object revision.
org.pentaho.di.core.logging.LoggingObjectType	getObjectType() Gets LoggingObjectType.JOB, which is always the value for Job.
String	getParameterDefault(String key)
String	getParameterDescription(String key)
String	getParameterValue(String key)
org.pentaho.di.core.logging.LoggingObjectInterface	getParent() Gets parent logging object.
Job	getParentJob() Gets the parent job.
org.pentaho.di.core.logging.LoggingObjectInterface	getParentLoggingObject() Gets the parent logging object.
Trans	getParentTrans()
org.pentaho.di.core.variables.VariableSpace	getParentVariableSpace()
long	getPassedBatchId() Gets the passedBatchId.
Date	getRegistrationDate() Gets the registration date.
Repository	getRep() Gets the rep (repository).
org.pentaho.di.repository.RepositoryDirectoryInterface	getRepositoryDirectory() Gets the job meta's repository directory interface.
org.pentaho.di.core.Result	getResult() Gets the result.
SocketRepository	getSocketRepository() Gets the socket repository.
List<org.pentaho.di.core.RowMetaAndData>	getSourceRows() Gets the source rows.
Date	getStartDate() Gets the start date.
JobEntryCopy	getStartJobEntryCopy() Gets the start job entry copy.
org.pentaho.di.core.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(org.pentaho.di.core.variables.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(org.pentaho.di.core.variables.VariableSpace var) Sets the internal kettle variables.
void	setJobTracker(JobTracker jobTracker) Sets the job tracker.
void	setLogLevel(org.pentaho.di.core.logging.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(org.pentaho.di.core.variables.VariableSpace parent)
void	setPassedBatchId(long jobBatchId) Sets the passedBatchId.
void	setRepository(Repository rep) Sets the repository.
void	setResult(org.pentaho.di.core.Result result) Sets the result.
void	setSocketRepository(SocketRepository socketRepository) Sets the socket repository.
void	setSourceRows(List<org.pentaho.di.core.RowMetaAndData> sourceRows) Sets the source rows.
void	setStartJobEntryCopy(JobEntryCopy startJobEntryCopy) Sets the start job entry copy.
void	setStartJobEntryResult(org.pentaho.di.core.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(org.pentaho.di.core.variables.VariableSpace 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,
           org.pentaho.di.core.logging.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 org.pentaho.di.core.exception.KettleException

Creates the job with new class loader.

Returns:

the job

Throws:

org.pentaho.di.core.exception.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 org.pentaho.di.core.Result execute(int nr,
                                          org.pentaho.di.core.Result result)
                                   throws org.pentaho.di.core.exception.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:

org.pentaho.di.core.exception.KettleJobException

org.pentaho.di.core.exception.KettleException

fireJobFinishListeners

public void fireJobFinishListeners()
                            throws org.pentaho.di.core.exception.KettleException

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

Throws:

org.pentaho.di.core.exception.KettleException

See Also:

JobListener.jobFinished(Job)

fireJobStartListeners

public void fireJobStartListeners()
                           throws org.pentaho.di.core.exception.KettleException

Call all the jobStarted method for each listener.

Throws:

org.pentaho.di.core.exception.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 org.pentaho.di.core.exception.KettleException

Handle logging at start

Returns:

true if it went OK.

Throws:

org.pentaho.di.core.exception.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:

Returns the jobTracker

setJobTracker

public void setJobTracker(JobTracker jobTracker)

Sets the job tracker.

Parameters:

jobTracker - The jobTracker to set

setSourceRows

public void setSourceRows(List<org.pentaho.di.core.RowMetaAndData> sourceRows)

Sets the source rows.

Parameters:

sourceRows - the new source rows

getSourceRows

public List<org.pentaho.di.core.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 org.pentaho.di.core.Result getResult()

Gets the result.

Returns:

the result

setResult

public void setResult(org.pentaho.di.core.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(org.pentaho.di.core.variables.VariableSpace var)

Sets the internal kettle variables.

Parameters:

var - the new internal kettle variables.

copyVariablesFrom

public void copyVariablesFrom(org.pentaho.di.core.variables.VariableSpace space)

Specified by:

copyVariablesFrom in interface org.pentaho.di.core.variables.VariableSpace

environmentSubstitute

public String environmentSubstitute(String aString)

Specified by:

environmentSubstitute in interface org.pentaho.di.core.variables.VariableSpace

environmentSubstitute

public String[] environmentSubstitute(String[] aString)

Specified by:

environmentSubstitute in interface org.pentaho.di.core.variables.VariableSpace

fieldSubstitute

public String fieldSubstitute(String aString,
                              org.pentaho.di.core.row.RowMetaInterface rowMeta,
                              Object[] rowData)
                       throws org.pentaho.di.core.exception.KettleValueException

Specified by:

fieldSubstitute in interface org.pentaho.di.core.variables.VariableSpace

Throws:

org.pentaho.di.core.exception.KettleValueException

getParentVariableSpace

public org.pentaho.di.core.variables.VariableSpace getParentVariableSpace()

Specified by:

getParentVariableSpace in interface org.pentaho.di.core.variables.VariableSpace

setParentVariableSpace

public void setParentVariableSpace(org.pentaho.di.core.variables.VariableSpace parent)

Specified by:

setParentVariableSpace in interface org.pentaho.di.core.variables.VariableSpace

getVariable

public String getVariable(String variableName,
                          String defaultValue)

Specified by:

getVariable in interface org.pentaho.di.core.variables.VariableSpace

getVariable

public String getVariable(String variableName)

Specified by:

getVariable in interface org.pentaho.di.core.variables.VariableSpace

getBooleanValueOfVariable

public boolean getBooleanValueOfVariable(String variableName,
                                         boolean defaultValue)

Specified by:

getBooleanValueOfVariable in interface org.pentaho.di.core.variables.VariableSpace

initializeVariablesFrom

public void initializeVariablesFrom(org.pentaho.di.core.variables.VariableSpace parent)

Specified by:

initializeVariablesFrom in interface org.pentaho.di.core.variables.VariableSpace

listVariables

public String[] listVariables()

Specified by:

listVariables in interface org.pentaho.di.core.variables.VariableSpace

setVariable

public void setVariable(String variableName,
                        String variableValue)

Specified by:

setVariable in interface org.pentaho.di.core.variables.VariableSpace

shareVariablesWith

public void shareVariablesWith(org.pentaho.di.core.variables.VariableSpace space)

Specified by:

shareVariablesWith in interface org.pentaho.di.core.variables.VariableSpace

injectVariables

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

Specified by:

injectVariables in interface org.pentaho.di.core.variables.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 org.pentaho.di.core.exception.KettleException

Send to slave server.

Parameters:

jobMeta - the job meta

executionConfiguration - the execution configuration

repository - the repository

metaStore - the metaStore

Returns:

the string

Throws:

org.pentaho.di.core.exception.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 org.pentaho.di.core.parameters.DuplicateParamException

Specified by:

addParameterDefinition in interface org.pentaho.di.core.parameters.NamedParams

Throws:

org.pentaho.di.core.parameters.DuplicateParamException

getParameterDescription

public String getParameterDescription(String key)
                               throws org.pentaho.di.core.parameters.UnknownParamException

Specified by:

getParameterDescription in interface org.pentaho.di.core.parameters.NamedParams

Throws:

org.pentaho.di.core.parameters.UnknownParamException

getParameterDefault

public String getParameterDefault(String key)
                           throws org.pentaho.di.core.parameters.UnknownParamException

Specified by:

getParameterDefault in interface org.pentaho.di.core.parameters.NamedParams

Throws:

org.pentaho.di.core.parameters.UnknownParamException

getParameterValue

public String getParameterValue(String key)
                         throws org.pentaho.di.core.parameters.UnknownParamException

Specified by:

getParameterValue in interface org.pentaho.di.core.parameters.NamedParams

Throws:

org.pentaho.di.core.parameters.UnknownParamException

listParameters

public String[] listParameters()

Specified by:

listParameters in interface org.pentaho.di.core.parameters.NamedParams

setParameterValue

public void setParameterValue(String key,
                              String value)
                       throws org.pentaho.di.core.parameters.UnknownParamException

Specified by:

setParameterValue in interface org.pentaho.di.core.parameters.NamedParams

Throws:

org.pentaho.di.core.parameters.UnknownParamException

eraseParameters

public void eraseParameters()

Specified by:

eraseParameters in interface org.pentaho.di.core.parameters.NamedParams

clearParameters

public void clearParameters()

Specified by:

clearParameters in interface org.pentaho.di.core.parameters.NamedParams

activateParameters

public void activateParameters()

Specified by:

activateParameters in interface org.pentaho.di.core.parameters.NamedParams

copyParametersFrom

public void copyParametersFrom(org.pentaho.di.core.parameters.NamedParams params)

Specified by:

copyParametersFrom in interface org.pentaho.di.core.parameters.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 org.pentaho.di.core.logging.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 org.pentaho.di.core.logging.LoggingObjectInterface

Returns:

jobName

getObjectCopy

public String getObjectCopy()

Always returns null for Job.

Specified by:

getObjectCopy in interface org.pentaho.di.core.logging.LoggingObjectInterface

Returns:

null

getFilename

public String getFilename()

Gets the file name.

Specified by:

getFilename in interface org.pentaho.di.core.logging.LoggingObjectInterface

Returns:

the filename

getLogChannelId

public String getLogChannelId()

Gets the log channel id.

Specified by:

getLogChannelId in interface org.pentaho.di.core.logging.LoggingObjectInterface

Returns:

the logChannelId

getObjectId

public org.pentaho.di.repository.ObjectId getObjectId()

Gets the jobMeta's object id.

Specified by:

getObjectId in interface org.pentaho.di.core.logging.LoggingObjectInterface

Returns:

ObjectId

getObjectRevision

public org.pentaho.di.repository.ObjectRevision getObjectRevision()

Gets the job meta's object revision.

Specified by:

getObjectRevision in interface org.pentaho.di.core.logging.LoggingObjectInterface

Returns:

ObjectRevision

getObjectType

public org.pentaho.di.core.logging.LoggingObjectType getObjectType()

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

Specified by:

getObjectType in interface org.pentaho.di.core.logging.LoggingObjectInterface

Returns:

LoggingObjectType LoggingObjectType.JOB

getParent

public org.pentaho.di.core.logging.LoggingObjectInterface getParent()

Gets parent logging object.

Specified by:

getParent in interface org.pentaho.di.core.logging.LoggingObjectInterface

Returns:

parentLoggingObject

getRepositoryDirectory

public org.pentaho.di.repository.RepositoryDirectoryInterface getRepositoryDirectory()

Gets the job meta's repository directory interface.

Specified by:

getRepositoryDirectory in interface org.pentaho.di.core.logging.LoggingObjectInterface

Returns:

RepositoryDirectoryInterface

getLogLevel

public org.pentaho.di.core.logging.LogLevel getLogLevel()

Gets the logLevel.

Specified by:

getLogLevel in interface org.pentaho.di.core.logging.LoggingObjectInterface

Returns:

logLevel

setLogLevel

public void setLogLevel(org.pentaho.di.core.logging.LogLevel logLevel)

Sets the log level.

Parameters:

logLevel - the new log level

getLoggingHierarchy

public List<org.pentaho.di.core.logging.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 org.pentaho.di.core.logging.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 org.pentaho.di.core.logging.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 org.pentaho.di.core.logging.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 org.pentaho.di.core.logging.LoggingObjectInterface

setGatheringMetrics

public void setGatheringMetrics(boolean gatheringMetrics)

Specified by:

setGatheringMetrics in interface org.pentaho.di.core.logging.LoggingObjectInterface

isForcingSeparateLogging

public boolean isForcingSeparateLogging()

Specified by:

isForcingSeparateLogging in interface org.pentaho.di.core.logging.LoggingObjectInterface

setForcingSeparateLogging

public void setForcingSeparateLogging(boolean forcingSeparateLogging)

Specified by:

setForcingSeparateLogging in interface org.pentaho.di.core.logging.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 org.pentaho.di.core.ExtensionDataInterface

getStartJobEntryResult

public org.pentaho.di.core.Result getStartJobEntryResult()

setStartJobEntryResult

public void setStartJobEntryResult(org.pentaho.di.core.Result startJobEntryResult)