org.pentaho.di.job
Class JobMeta

java.lang.Object
  org.pentaho.di.core.changed.ChangedFlag
      org.pentaho.di.job.JobMeta

All Implemented Interfaces:

Cloneable, Comparable<JobMeta>, ChangedFlagInterface, EngineMetaInterface, UndoInterface, org.pentaho.di.core.logging.LoggingObjectInterface, org.pentaho.di.core.parameters.NamedParams, org.pentaho.di.core.variables.VariableSpace, org.pentaho.di.core.xml.XMLInterface, HasRepositoryInterface, org.pentaho.di.repository.RepositoryElementInterface, org.pentaho.di.repository.RepositoryObjectInterface, ResourceExportInterface, HasDatabasesInterface, HasSlaveServersInterface

public class JobMeta
extends ChangedFlag
implements Cloneable, Comparable<JobMeta>, org.pentaho.di.core.xml.XMLInterface, UndoInterface, HasDatabasesInterface, org.pentaho.di.core.variables.VariableSpace, EngineMetaInterface, ResourceExportInterface, HasSlaveServersInterface, org.pentaho.di.core.parameters.NamedParams, org.pentaho.di.repository.RepositoryElementInterface, org.pentaho.di.core.logging.LoggingObjectInterface, HasRepositoryInterface

Defines a Job and provides methods to load, save, verify, etc.

Since:

11-08-2003

Author:

Matt

Field Summary

boolean[]	max
static org.pentaho.di.repository.RepositoryObjectType	REPOSITORY_ELEMENT_TYPE
static String	STRING_SPECIAL
static String	STRING_SPECIAL_DUMMY
static String	STRING_SPECIAL_ERROR
static String	STRING_SPECIAL_OK
static String	STRING_SPECIAL_START
static int	TYPE_UNDO_CHANGE
static int	TYPE_UNDO_DELETE
static int	TYPE_UNDO_NEW
static int	TYPE_UNDO_POSITION
static String	XML_TAG

Constructor Summary

JobMeta()

JobMeta(InputStream inputStream, Repository rep, org.pentaho.di.core.gui.OverwritePrompter prompter)

JobMeta(Node jobnode, Repository rep, boolean ignoreRepositorySharedObjects, org.pentaho.di.core.gui.OverwritePrompter prompter)
Create a new JobMeta object by loading it from a a DOM node.

JobMeta(Node jobnode, Repository rep, org.pentaho.di.core.gui.OverwritePrompter prompter)
Create a new JobMeta object by loading it from a a DOM node.

JobMeta(String fname, Repository rep)

JobMeta(String fname, Repository rep, org.pentaho.di.core.gui.OverwritePrompter prompter)

JobMeta(org.pentaho.di.core.variables.VariableSpace parentSpace, String fname, Repository rep, org.pentaho.di.core.gui.OverwritePrompter prompter)
Load the job from the XML file specified.

Method Summary

void	activateParameters()
void	addDatabase(org.pentaho.di.core.database.DatabaseMeta ci) Add a database connection to the transformation.
void	addDatabase(int p, org.pentaho.di.core.database.DatabaseMeta ci) Add a database connection to the transformation on a certain location.
void	addDefaults()
void	addFilenameChangedListener(FilenameChangedListener listener)
void	addJobEntry(int p, JobEntryCopy si)
void	addJobEntry(JobEntryCopy je)
void	addJobHop(int p, JobHopMeta hi)
void	addJobHop(JobHopMeta hi)
void	addNameChangedListener(NameChangedListener listener)
void	addNote(int p, NotePadMeta ni)
void	addNote(NotePadMeta ni)
void	addOrReplaceDatabase(org.pentaho.di.core.database.DatabaseMeta databaseMeta) Add a database connection to the transformation if that connection didn't exists yet.
void	addOrReplaceSlaveServer(SlaveServer slaveServer) Add a new slave server to the transformation if that didn't exist yet.
void	addParameterDefinition(String key, String defValue, String description)
void	addUndo(Object[] from, Object[] to, int[] pos, org.pentaho.di.core.gui.Point[] prev, org.pentaho.di.core.gui.Point[] curr, int type_of_change, boolean nextAlso) Add an undo operation to the undo list
boolean	canSave()
void	checkJobEntries(List<org.pentaho.di.core.CheckResultInterface> remarks, boolean only_selected, org.pentaho.di.core.ProgressMonitorListener monitor) Check all job entries within the job.
void	clear()
void	clearChanged()
void	clearParameters()
void	clearUndo()
Object	clone()
int	compare(JobMeta j1, JobMeta j2) Compares two transformation on name, filename
int	compareTo(JobMeta o)
List<JobEntryInterface>	composeJobEntryInterfaceList() Create a unique list of job entry interfaces
void	copyParametersFrom(org.pentaho.di.core.parameters.NamedParams params)
void	copyVariablesFrom(org.pentaho.di.core.variables.VariableSpace space)
int	countEntries(String name)
static JobEntryCopy	createDummyEntry()
static JobEntryCopy	createStartEntry()
String	environmentSubstitute(String aString)
String[]	environmentSubstitute(String[] aString)
boolean	equals(Object obj)
void	eraseParameters()
String	exportResources(org.pentaho.di.core.variables.VariableSpace space, Map<String,ResourceDefinition> definitions, ResourceNamingInterface namingInterface, Repository repository) Exports the object to a flat-file system, adding content with filename keys to a set of definitions.
org.pentaho.di.core.database.DatabaseMeta	findDatabase(String name) Find a database connection by it's name
static JobEntryInterface	findJobEntry(List<JobEntryInterface> jobentries, org.pentaho.di.repository.ObjectId id_jobentry) Find a jobentry with a certain ID in a list of job entries.
JobEntryCopy	findJobEntry(String full_name_nr)
JobEntryCopy	findJobEntry(String name, int nr, boolean searchHiddenToo) Find an existing JobEntryCopy by it's name and number
static JobEntryCopy	findJobEntryCopy(List<JobEntryCopy> jobcopies, org.pentaho.di.repository.ObjectId id_jobentry_copy) Find a jobentrycopy with a certain ID in a list of job entry copies.
JobHopMeta	findJobHop(JobEntryCopy from, JobEntryCopy to)
JobHopMeta	findJobHop(JobEntryCopy from, JobEntryCopy to, boolean includeDisabled)
JobHopMeta	findJobHop(String name)
JobHopMeta	findJobHopFrom(JobEntryCopy jge)
JobHopMeta	findJobHopTo(JobEntryCopy jge)
int	findMaxNr(String name)
JobEntryCopy	findNextJobEntry(JobEntryCopy from, int cnt)
int	findNrNextJobEntries(JobEntryCopy from)
int	findNrPrevJobEntries(JobEntryCopy from)
int	findNrPrevJobEntries(JobEntryCopy to, boolean info)
JobEntryCopy	findPrevJobEntry(JobEntryCopy to, int nr)
JobEntryCopy	findPrevJobEntry(JobEntryCopy to, int nr, boolean info)
SlaveServer	findSlaveServer(String serverString) Find a slave server using the name
JobEntryCopy	findStart()
int	findUnusedNr(String name)
JobEntryCopy[]	getAllJobGraphEntries(String name)
JobHopMeta[]	getAllJobHopsUsing(String name)
String	getAlternativeJobentryName(String entryname) Proposes an alternative job entry name when the original already exists...
String[]	getArguments()
boolean	getBooleanValueOfVariable(String variableName, boolean defaultValue)
ChannelLogTable	getChannelLogTable()
String	getContainerObjectId()
Date	getCreatedDate()
String	getCreatedUser()
org.pentaho.di.core.database.DatabaseMeta	getDatabase(int i) Retrieves a database connection information a a certain location.
String[]	getDatabaseNames()
List<org.pentaho.di.core.database.DatabaseMeta>	getDatabases() Get an ArrayList of defined DatabaseInfo objects.
String	getDefaultExtension()
String	getDescription()
JobEntryCopy	getDummy()
int[]	getEntryIndexes(List<JobEntryCopy> entries)
String	getExtendedDescription()
String	getFilename()
String	getFileType()
String[]	getFilterExtensions()
String[]	getFilterNames()
List<JobEntryCopy>	getJobCopies()
JobEntryCopy	getJobEntry(int i)
JobEntryCopy	getJobEntryCopy(int x, int y, int iconsize)
JobEntryLogTable	getJobEntryLogTable()
JobHopMeta	getJobHop(int i)
List<JobHopMeta>	getJobhops()
JobLogTable	getJobLogTable()
int	getJobstatus() Get the status of the job
String	getJobversion()
String	getLogChannelId()
org.pentaho.di.core.logging.LogLevel	getLogLevel()
List<org.pentaho.di.core.logging.LogTableInterface>	getLogTables()
org.pentaho.di.core.gui.Point	getMaximum()
int	getMaxUndo() Get the maximum number of undo operations possible
org.pentaho.di.core.gui.Point	getMinimum() Get the minimum point on the canvas of a job
Date	getModifiedDate()
String	getModifiedUser()
String	getName()
NotePadMeta	getNote(int i)
NotePadMeta	getNote(int x, int y)
int[]	getNoteIndexes(List<NotePadMeta> notes) Get an array of the locations of an array of notes
List<NotePadMeta>	getNotes()
String	getObjectCopy()
org.pentaho.di.repository.ObjectId	getObjectId()
String	getObjectName()
org.pentaho.di.repository.ObjectRevision	getObjectRevision()
org.pentaho.di.core.logging.LoggingObjectType	getObjectType()
String	getParameterDefault(String key)
String	getParameterDescription(String key)
String	getParameterValue(String key)
org.pentaho.di.core.logging.LoggingObjectInterface	getParent()
org.pentaho.di.core.variables.VariableSpace	getParentVariableSpace()
Date	getRegistrationDate() Stub
Repository	getRepository()
org.pentaho.di.repository.RepositoryDirectoryInterface	getRepositoryDirectory()
org.pentaho.di.repository.RepositoryObjectType	getRepositoryElementType()
List<ResourceReference>	getResourceDependencies()
List<JobEntryCopy>	getSelectedEntries()
org.pentaho.di.core.gui.Point[]	getSelectedLocations()
org.pentaho.di.core.gui.Point[]	getSelectedNoteLocations() Get all the selected note locations
List<NotePadMeta>	getSelectedNotes()
SharedObjects	getSharedObjects()
String	getSharedObjectsFile()
String[]	getSlaveServerNames()
List<SlaveServer>	getSlaveServers()
List<org.pentaho.di.core.SQLStatement>	getSQLStatements(Repository repository, org.pentaho.di.core.ProgressMonitorListener monitor) Builds a list of all the SQL statements that this transformation needs in order to work properly.
JobEntryCopy	getStart()
List<StringSearchResult>	getStringList(boolean searchSteps, boolean searchDatabases, boolean searchNotes) Get a list of all the strings used in this job.
int	getUndoSize()
List<String>	getUsedVariables()
String	getVariable(String variableName)
String	getVariable(String variableName, String defaultValue)
String	getXML()
boolean	hasChanged()
boolean	hasLoop(JobEntryCopy entry)
boolean	hasLoop(JobEntryCopy entry, JobEntryCopy lookup)
boolean	hasRepositoryReferences()
boolean	haveConnectionsChanged() Checks whether or not the connections have changed.
boolean	haveJobEntriesChanged()
boolean	haveJobHopsChanged()
boolean	haveNotesChanged()
int	indexOfDatabase(org.pentaho.di.core.database.DatabaseMeta di) Find the location of database
int	indexOfJobEntry(JobEntryCopy ge)
int	indexOfJobHop(JobHopMeta he)
int	indexOfNote(NotePadMeta ni)
void	initializeVariablesFrom(org.pentaho.di.core.variables.VariableSpace parent)
void	injectVariables(Map<String,String> prop)
boolean	isBatchIdPassed()
boolean	isDatabaseConnectionUsed(org.pentaho.di.core.database.DatabaseMeta databaseMeta) This method asks all steps in the transformation whether or not the specified database connection is used.
boolean	isEntryUsedInHops(JobEntryCopy jge)
boolean	isFileReference()
static boolean	isFileReference(String fileName, String transName)
boolean	isRepReference()
static boolean	isRepReference(String fileName, String transName)
String[]	listParameters()
String[]	listVariables()
void	loadXML(Node jobnode, Repository rep, boolean ignoreRepositorySharedObjects, org.pentaho.di.core.gui.OverwritePrompter prompter) Load a block of XML from an DOM node.
void	loadXML(Node jobnode, Repository rep, org.pentaho.di.core.gui.OverwritePrompter prompter)
void	lookupRepositoryReferences(Repository repository) Look up the references after import
void	lowerNote(int p)
void	nameFromFilename() Builds a name - if no name is set, yet - from the filename
TransAction	nextUndo() Get the next undo transaction on the list.
int	nrDatabases() Count the nr of databases in the transformation.
int	nrJobEntries()
int	nrJobHops()
int	nrNotes()
TransAction	previousUndo() Get the previous undo operation and change the undo pointer
void	raiseNote(int p)
SharedObjects	readSharedObjects()
Object	realClone(boolean doClear)
void	removeDatabase(int i) Removes a database from the transformation on a certain location.
void	removeFilenameChangedListener(FilenameChangedListener listener)
void	removeJobEntry(int i)
void	removeJobHop(int i)
void	removeNameChangedListener(NameChangedListener listener)
void	removeNote(int i)
void	renameJobEntryIfNameCollides(JobEntryCopy je) See if the name of the supplied job entry copy doesn't collide with any other job entry copy in the job.
void	saveSharedObjects()
void	selectAll()
void	setArguments(String[] arguments)
void	setBatchIdPassed(boolean batchIdPassed)
void	setCarteObjectId(String containerObjectId)
void	setChanged(boolean ch)
void	setChannelLogTable(ChannelLogTable channelLogTable)
void	setCreatedDate(Date createdDate)
void	setCreatedUser(String createdUser)
void	setDatabases(List<org.pentaho.di.core.database.DatabaseMeta> databases)
void	setDescription(String description) Set the description of the job.
void	setExtendedDescription(String extendedDescription) Set the description of the job.
void	setFilename(String newFilename) Set the filename of the job
void	setInternalKettleVariables() Calls setInternalKettleVariables on the default object.
void	setInternalKettleVariables(org.pentaho.di.core.variables.VariableSpace var) This method sets various internal kettle variables that can be used by the transformation.
void	setJobEntry(int idx, JobEntryCopy jec)
void	setJobEntryLogTable(JobEntryLogTable jobEntryLogTable)
void	setJobLogTable(JobLogTable jobLogTable)
void	setJobstatus(int jobStatus) Set the status of the job.
void	setJobversion(String jobVersion) Set the version of the job.
void	setLogLevel(org.pentaho.di.core.logging.LogLevel logLevel)
void	setMaxUndo(int mu) Sets the maximum number of undo operations that are allowed.
void	setModifiedDate(Date modifiedDate)
void	setModifiedUser(String modifiedUser)
void	setName(String newName) Set the name of the job.
void	setObjectId(org.pentaho.di.repository.ObjectId objectId)
void	setObjectRevision(org.pentaho.di.repository.ObjectRevision objectRevision)
void	setParameterValue(String key, String value)
void	setParentVariableSpace(org.pentaho.di.core.variables.VariableSpace parent)
void	setRepository(Repository repository)
void	setRepositoryDirectory(org.pentaho.di.repository.RepositoryDirectoryInterface directory)
void	setSharedObjects(SharedObjects sharedObjects)
void	setSharedObjectsFile(String sharedObjectsFile)
void	setSlaveServers(List<SlaveServer> slaveServers)
void	setVariable(String variableName, String variableValue)
void	shareVariablesWith(org.pentaho.di.core.variables.VariableSpace space)
String	toString()
void	unselectAll()
TransAction	viewNextUndo() Get the next undo transaction on the list.
TransAction	viewPreviousUndo() View previous undo, don't change undo position
TransAction	viewThisUndo() View current undo, don't change undo position

Methods inherited from class org.pentaho.di.core.changed.ChangedFlag

addObserver, deleteObserver, notifyObservers, setChanged

Methods inherited from class java.lang.Object

getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

XML_TAG

public static final String XML_TAG

See Also:

Constant Field Values

REPOSITORY_ELEMENT_TYPE

public static final org.pentaho.di.repository.RepositoryObjectType REPOSITORY_ELEMENT_TYPE

TYPE_UNDO_CHANGE

public static final int TYPE_UNDO_CHANGE

See Also:

Constant Field Values

TYPE_UNDO_NEW

public static final int TYPE_UNDO_NEW

See Also:

Constant Field Values

TYPE_UNDO_DELETE

public static final int TYPE_UNDO_DELETE

See Also:

Constant Field Values

TYPE_UNDO_POSITION

public static final int TYPE_UNDO_POSITION

See Also:

Constant Field Values

STRING_SPECIAL

public static final String STRING_SPECIAL

See Also:

Constant Field Values

STRING_SPECIAL_START

public static final String STRING_SPECIAL_START

See Also:

Constant Field Values

STRING_SPECIAL_DUMMY

public static final String STRING_SPECIAL_DUMMY

See Also:

Constant Field Values

STRING_SPECIAL_OK

public static final String STRING_SPECIAL_OK

See Also:

Constant Field Values

STRING_SPECIAL_ERROR

public static final String STRING_SPECIAL_ERROR

See Also:

Constant Field Values

max

public boolean[] max

Constructor Detail

JobMeta

public JobMeta()

JobMeta

public JobMeta(String fname,
               Repository rep)
        throws org.pentaho.di.core.exception.KettleXMLException

Throws:

org.pentaho.di.core.exception.KettleXMLException

JobMeta

public JobMeta(String fname,
               Repository rep,
               org.pentaho.di.core.gui.OverwritePrompter prompter)
        throws org.pentaho.di.core.exception.KettleXMLException

Throws:

org.pentaho.di.core.exception.KettleXMLException

JobMeta

public JobMeta(org.pentaho.di.core.variables.VariableSpace parentSpace,
               String fname,
               Repository rep,
               org.pentaho.di.core.gui.OverwritePrompter prompter)
        throws org.pentaho.di.core.exception.KettleXMLException

Load the job from the XML file specified.

Parameters:

log - the logging channel

fname - The filename to load as a job

rep - The repository to bind againt, null if there is no repository available.

Throws:

org.pentaho.di.core.exception.KettleXMLException

JobMeta

public JobMeta(InputStream inputStream,
               Repository rep,
               org.pentaho.di.core.gui.OverwritePrompter prompter)
        throws org.pentaho.di.core.exception.KettleXMLException

Throws:

org.pentaho.di.core.exception.KettleXMLException

JobMeta

public JobMeta(Node jobnode,
               Repository rep,
               org.pentaho.di.core.gui.OverwritePrompter prompter)
        throws org.pentaho.di.core.exception.KettleXMLException

Create a new JobMeta object by loading it from a a DOM node.

Parameters:

jobnode - The node to load from

rep - The reference to a repository to load additional information from

prompter - The prompter to use in case a shared object gets overwritten

Throws:

org.pentaho.di.core.exception.KettleXMLException

JobMeta

public JobMeta(Node jobnode,
               Repository rep,
               boolean ignoreRepositorySharedObjects,
               org.pentaho.di.core.gui.OverwritePrompter prompter)
        throws org.pentaho.di.core.exception.KettleXMLException

Create a new JobMeta object by loading it from a a DOM node.

Parameters:

jobnode - The node to load from

rep - The reference to a repository to load additional information from

ignoreRepositorySharedObjects - Do not load shared objects, handled separately

prompter - The prompter to use in case a shared object gets overwritten

Throws:

org.pentaho.di.core.exception.KettleXMLException

Method Detail

getObjectId

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

Specified by:

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

Specified by:

getObjectId in interface org.pentaho.di.repository.RepositoryElementInterface

Specified by:

getObjectId in interface org.pentaho.di.repository.RepositoryObjectInterface

setObjectId

public void setObjectId(org.pentaho.di.repository.ObjectId objectId)

Specified by:

setObjectId in interface EngineMetaInterface

Specified by:

setObjectId in interface org.pentaho.di.repository.RepositoryElementInterface

clear

public void clear()

addDefaults

public void addDefaults()

createStartEntry

public static final JobEntryCopy createStartEntry()

createDummyEntry

public static final JobEntryCopy createDummyEntry()

getStart

public JobEntryCopy getStart()

getDummy

public JobEntryCopy getDummy()

compare

public int compare(JobMeta j1,
                   JobMeta j2)

Compares two transformation on name, filename

compareTo

public int compareTo(JobMeta o)

Specified by:

compareTo in interface Comparable<JobMeta>

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

clone

public Object clone()

Overrides:

clone in class Object

realClone

public Object realClone(boolean doClear)

getName

public String getName()

Specified by:

getName in interface EngineMetaInterface

Specified by:

getName in interface org.pentaho.di.repository.RepositoryElementInterface

Specified by:

getName in interface org.pentaho.di.repository.RepositoryObjectInterface

setName

public void setName(String newName)

Set the name of the job.

Specified by:

setName in interface org.pentaho.di.repository.RepositoryElementInterface

Parameters:

newName - The new name of the job

nameFromFilename

public void nameFromFilename()

Builds a name - if no name is set, yet - from the filename

Specified by:

nameFromFilename in interface EngineMetaInterface

getRepositoryDirectory

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

Specified by:

getRepositoryDirectory in interface EngineMetaInterface

Specified by:

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

Specified by:

getRepositoryDirectory in interface org.pentaho.di.repository.RepositoryElementInterface

Returns:

Returns the directory.

setRepositoryDirectory

public void setRepositoryDirectory(org.pentaho.di.repository.RepositoryDirectoryInterface directory)

Specified by:

setRepositoryDirectory in interface org.pentaho.di.repository.RepositoryElementInterface

Parameters:

directory - The directory to set.

getFilename

public String getFilename()

Specified by:

getFilename in interface EngineMetaInterface

Specified by:

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

setFilename

public void setFilename(String newFilename)

Set the filename of the job

Specified by:

setFilename in interface EngineMetaInterface

Parameters:

newFilename - The new filename of the job

getJobLogTable

public JobLogTable getJobLogTable()

setJobLogTable

public void setJobLogTable(JobLogTable jobLogTable)

getDatabases

public List<org.pentaho.di.core.database.DatabaseMeta> getDatabases()

Description copied from interface: HasDatabasesInterface

Get an ArrayList of defined DatabaseInfo objects.

Specified by:

getDatabases in interface HasDatabasesInterface

Returns:

Returns the databases.

getDatabaseNames

public String[] getDatabaseNames()

setDatabases

public void setDatabases(List<org.pentaho.di.core.database.DatabaseMeta> databases)

Specified by:

setDatabases in interface HasDatabasesInterface

Parameters:

databases - The databases to set.

setChanged

public void setChanged(boolean ch)

Specified by:

setChanged in interface ChangedFlagInterface

Overrides:

setChanged in class ChangedFlag

clearChanged

public void clearChanged()

Specified by:

clearChanged in interface ChangedFlagInterface

Specified by:

clearChanged in interface EngineMetaInterface

Overrides:

clearChanged in class ChangedFlag

hasChanged

public boolean hasChanged()

Specified by:

hasChanged in interface ChangedFlagInterface

Overrides:

hasChanged in class ChangedFlag

isDatabaseConnectionUsed

public boolean isDatabaseConnectionUsed(org.pentaho.di.core.database.DatabaseMeta databaseMeta)

This method asks all steps in the transformation whether or not the specified database connection is used. The connection is used in the transformation if any of the steps uses it or if it is being used to log to.

Parameters:

databaseMeta - The connection to check

Returns:

true if the connection is used in this transformation.

getFileType

public String getFileType()

Specified by:

getFileType in interface EngineMetaInterface

getFilterNames

public String[] getFilterNames()

Specified by:

getFilterNames in interface EngineMetaInterface

getFilterExtensions

public String[] getFilterExtensions()

Specified by:

getFilterExtensions in interface EngineMetaInterface

getDefaultExtension

public String getDefaultExtension()

Specified by:

getDefaultExtension in interface EngineMetaInterface

getXML

public String getXML()

Specified by:

getXML in interface EngineMetaInterface

Specified by:

getXML in interface org.pentaho.di.core.xml.XMLInterface

isRepReference

public boolean isRepReference()

isFileReference

public boolean isFileReference()

isRepReference

public static boolean isRepReference(String fileName,
                                     String transName)

isFileReference

public static boolean isFileReference(String fileName,
                                      String transName)

loadXML

public void loadXML(Node jobnode,
                    Repository rep,
                    org.pentaho.di.core.gui.OverwritePrompter prompter)
             throws org.pentaho.di.core.exception.KettleXMLException

Throws:

org.pentaho.di.core.exception.KettleXMLException

loadXML

public void loadXML(Node jobnode,
                    Repository rep,
                    boolean ignoreRepositorySharedObjects,
                    org.pentaho.di.core.gui.OverwritePrompter prompter)
             throws org.pentaho.di.core.exception.KettleXMLException

Load a block of XML from an DOM node.

Parameters:

jobnode - The node to load from

rep - The reference to a repository to load additional information from

ignoreRepositorySharedObjects - Do not load shared objects, handled separately

prompter - The prompter to use in case a shared object gets overwritten

Throws:

org.pentaho.di.core.exception.KettleXMLException

readSharedObjects

public SharedObjects readSharedObjects()
                                throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

saveSharedObjects

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

Specified by:

saveSharedObjects in interface EngineMetaInterface

Throws:

org.pentaho.di.core.exception.KettleException

findDatabase

public org.pentaho.di.core.database.DatabaseMeta findDatabase(String name)

Find a database connection by it's name

Specified by:

findDatabase in interface HasDatabasesInterface

Parameters:

name - The database name to look for

Returns:

The database connection or null if nothing was found.

getJobEntryCopy

public JobEntryCopy getJobEntryCopy(int x,
                                    int y,
                                    int iconsize)

nrJobEntries

public int nrJobEntries()

nrJobHops

public int nrJobHops()

nrNotes

public int nrNotes()

nrDatabases

public int nrDatabases()

Description copied from interface: HasDatabasesInterface

Count the nr of databases in the transformation.

Specified by:

nrDatabases in interface HasDatabasesInterface

Returns:

The nr of databases

getJobHop

public JobHopMeta getJobHop(int i)

getJobEntry

public JobEntryCopy getJobEntry(int i)

getNote

public NotePadMeta getNote(int i)

getDatabase

public org.pentaho.di.core.database.DatabaseMeta getDatabase(int i)

Description copied from interface: HasDatabasesInterface

Retrieves a database connection information a a certain location.

Specified by:

getDatabase in interface HasDatabasesInterface

Parameters:

i - The database number.

Returns:

The database connection information.

addJobEntry

public void addJobEntry(JobEntryCopy je)

addJobHop

public void addJobHop(JobHopMeta hi)

addNote

public void addNote(NotePadMeta ni)

addDatabase

public void addDatabase(org.pentaho.di.core.database.DatabaseMeta ci)

Description copied from interface: HasDatabasesInterface

Add a database connection to the transformation.

Specified by:

addDatabase in interface HasDatabasesInterface

Parameters:

ci - The database connection information.

addJobEntry

public void addJobEntry(int p,
                        JobEntryCopy si)

addJobHop

public void addJobHop(int p,
                      JobHopMeta hi)

addNote

public void addNote(int p,
                    NotePadMeta ni)

addDatabase

public void addDatabase(int p,
                        org.pentaho.di.core.database.DatabaseMeta ci)

Description copied from interface: HasDatabasesInterface

Add a database connection to the transformation on a certain location.

Specified by:

addDatabase in interface HasDatabasesInterface

Parameters:

p - The location

ci - The database connection information.

addOrReplaceDatabase

public void addOrReplaceDatabase(org.pentaho.di.core.database.DatabaseMeta databaseMeta)

Description copied from interface: HasDatabasesInterface

Add a database connection to the transformation if that connection didn't exists yet. Otherwise, replace the connection in the transformation

Specified by:

addOrReplaceDatabase in interface HasDatabasesInterface

Parameters:

databaseMeta - The database connection information.

addOrReplaceSlaveServer

public void addOrReplaceSlaveServer(SlaveServer slaveServer)

Add a new slave server to the transformation if that didn't exist yet. Otherwise, replace it.

Parameters:

slaveServer - The slave server to be added.

removeJobEntry

public void removeJobEntry(int i)

removeJobHop

public void removeJobHop(int i)

removeNote

public void removeNote(int i)

raiseNote

public void raiseNote(int p)

lowerNote

public void lowerNote(int p)

removeDatabase

public void removeDatabase(int i)

Description copied from interface: HasDatabasesInterface

Removes a database from the transformation on a certain location.

Specified by:

removeDatabase in interface HasDatabasesInterface

Parameters:

i - The location

indexOfJobHop

public int indexOfJobHop(JobHopMeta he)

indexOfNote

public int indexOfNote(NotePadMeta ni)

indexOfJobEntry

public int indexOfJobEntry(JobEntryCopy ge)

indexOfDatabase

public int indexOfDatabase(org.pentaho.di.core.database.DatabaseMeta di)

Description copied from interface: HasDatabasesInterface

Find the location of database

Specified by:

indexOfDatabase in interface HasDatabasesInterface

Parameters:

di - The database queried

Returns:

The location of the database, -1 if nothing was found.

setJobEntry

public void setJobEntry(int idx,
                        JobEntryCopy jec)

findJobEntry

public JobEntryCopy findJobEntry(String name,
                                 int nr,
                                 boolean searchHiddenToo)

Find an existing JobEntryCopy by it's name and number

Parameters:

name - The name of the job entry copy

nr - The number of the job entry copy

Returns:

The JobEntryCopy or null if nothing was found!

findJobEntry

public JobEntryCopy findJobEntry(String full_name_nr)

findJobHop

public JobHopMeta findJobHop(String name)

findJobHopFrom

public JobHopMeta findJobHopFrom(JobEntryCopy jge)

findJobHop

public JobHopMeta findJobHop(JobEntryCopy from,
                             JobEntryCopy to)

findJobHop

public JobHopMeta findJobHop(JobEntryCopy from,
                             JobEntryCopy to,
                             boolean includeDisabled)

findJobHopTo

public JobHopMeta findJobHopTo(JobEntryCopy jge)

findNrPrevJobEntries

public int findNrPrevJobEntries(JobEntryCopy from)

findPrevJobEntry

public JobEntryCopy findPrevJobEntry(JobEntryCopy to,
                                     int nr)

findNrPrevJobEntries

public int findNrPrevJobEntries(JobEntryCopy to,
                                boolean info)

findPrevJobEntry

public JobEntryCopy findPrevJobEntry(JobEntryCopy to,
                                     int nr,
                                     boolean info)

findNrNextJobEntries

public int findNrNextJobEntries(JobEntryCopy from)

findNextJobEntry

public JobEntryCopy findNextJobEntry(JobEntryCopy from,
                                     int cnt)

hasLoop

public boolean hasLoop(JobEntryCopy entry)

hasLoop

public boolean hasLoop(JobEntryCopy entry,
                       JobEntryCopy lookup)

isEntryUsedInHops

public boolean isEntryUsedInHops(JobEntryCopy jge)

countEntries

public int countEntries(String name)

findUnusedNr

public int findUnusedNr(String name)

findMaxNr

public int findMaxNr(String name)

getAlternativeJobentryName

public String getAlternativeJobentryName(String entryname)

Proposes an alternative job entry name when the original already exists...

Parameters:

entryname - The job entry name to find an alternative for..

Returns:

The alternative stepname.

getAllJobGraphEntries

public JobEntryCopy[] getAllJobGraphEntries(String name)

getAllJobHopsUsing

public JobHopMeta[] getAllJobHopsUsing(String name)

getNote

public NotePadMeta getNote(int x,
                           int y)

selectAll

public void selectAll()

unselectAll

public void unselectAll()

getMaxUndo

public int getMaxUndo()

Description copied from interface: UndoInterface

Get the maximum number of undo operations possible

Specified by:

getMaxUndo in interface UndoInterface

Returns:

The maximum number of undo operations that are allowed.

setMaxUndo

public void setMaxUndo(int mu)

Description copied from interface: UndoInterface

Sets the maximum number of undo operations that are allowed.

Specified by:

setMaxUndo in interface UndoInterface

Parameters:

mu - The maximum number of undo operations that are allowed.

getUndoSize

public int getUndoSize()

clearUndo

public void clearUndo()

addUndo

public void addUndo(Object[] from,
                    Object[] to,
                    int[] pos,
                    org.pentaho.di.core.gui.Point[] prev,
                    org.pentaho.di.core.gui.Point[] curr,
                    int type_of_change,
                    boolean nextAlso)

Description copied from interface: UndoInterface

Add an undo operation to the undo list

Specified by:

addUndo in interface UndoInterface

Parameters:

from - array of objects representing the old state

to - array of objectes representing the new state

pos - An array of object locations

prev - An array of points representing the old positions

curr - An array of points representing the new positions

type_of_change - The type of change that's being done to the transformation.

nextAlso - indicates that the next undo operation needs to follow this one.

previousUndo

public TransAction previousUndo()

Description copied from interface: UndoInterface

Get the previous undo operation and change the undo pointer

Specified by:

previousUndo in interface UndoInterface

Returns:

The undo transaction to be performed.

viewThisUndo

public TransAction viewThisUndo()

View current undo, don't change undo position

Specified by:

viewThisUndo in interface UndoInterface

Returns:

The current undo transaction

viewPreviousUndo

public TransAction viewPreviousUndo()

Description copied from interface: UndoInterface

View previous undo, don't change undo position

Specified by:

viewPreviousUndo in interface UndoInterface

Returns:

The previous undo transaction

nextUndo

public TransAction nextUndo()

Description copied from interface: UndoInterface

Get the next undo transaction on the list. Change the undo pointer.

Specified by:

nextUndo in interface UndoInterface

Returns:

The next undo transaction (for redo)

viewNextUndo

public TransAction viewNextUndo()

Description copied from interface: UndoInterface

Get the next undo transaction on the list.

Specified by:

viewNextUndo in interface UndoInterface

Returns:

The next undo transaction (for redo)

getMaximum

public org.pentaho.di.core.gui.Point getMaximum()

getMinimum

public org.pentaho.di.core.gui.Point getMinimum()

Get the minimum point on the canvas of a job

Returns:

Minimum coordinate of a step in the job

getSelectedLocations

public org.pentaho.di.core.gui.Point[] getSelectedLocations()

getSelectedNoteLocations

public org.pentaho.di.core.gui.Point[] getSelectedNoteLocations()

Get all the selected note locations

Returns:

The selected step and notes locations.

getSelectedEntries

public List<JobEntryCopy> getSelectedEntries()

getSelectedNotes

public List<NotePadMeta> getSelectedNotes()

Returns:

A list of all the selected notes.

getEntryIndexes

public int[] getEntryIndexes(List<JobEntryCopy> entries)

getNoteIndexes

public int[] getNoteIndexes(List<NotePadMeta> notes)

Get an array of the locations of an array of notes

Parameters:

notes - An array of notes

Returns:

an array of the locations of an array of notes

findStart

public JobEntryCopy findStart()

toString

public String toString()

Overrides:

toString in class Object

isBatchIdPassed

public boolean isBatchIdPassed()

Returns:

Returns the batchIdPassed.

setBatchIdPassed

public void setBatchIdPassed(boolean batchIdPassed)

Parameters:

batchIdPassed - The batchIdPassed to set.

getSQLStatements

public List<org.pentaho.di.core.SQLStatement> getSQLStatements(Repository repository,
                                                               org.pentaho.di.core.ProgressMonitorListener monitor)
                                                        throws org.pentaho.di.core.exception.KettleException

Builds a list of all the SQL statements that this transformation needs in order to work properly.

Returns:

An ArrayList of SQLStatement objects.

Throws:

org.pentaho.di.core.exception.KettleException

getArguments

public String[] getArguments()

Returns:

Returns the arguments.

setArguments

public void setArguments(String[] arguments)

Parameters:

arguments - The arguments to set.

getStringList

public List<StringSearchResult> getStringList(boolean searchSteps,
                                              boolean searchDatabases,
                                              boolean searchNotes)

Get a list of all the strings used in this job.

Returns:

A list of StringSearchResult with strings used in the job

getUsedVariables

public List<String> getUsedVariables()

haveConnectionsChanged

public boolean haveConnectionsChanged()

Description copied from interface: HasDatabasesInterface

Checks whether or not the connections have changed.

Specified by:

haveConnectionsChanged in interface HasDatabasesInterface

Returns:

True if the connections have been changed.

haveJobEntriesChanged

public boolean haveJobEntriesChanged()

haveJobHopsChanged

public boolean haveJobHopsChanged()

haveNotesChanged

public boolean haveNotesChanged()

getSharedObjectsFile

public String getSharedObjectsFile()

Returns:

the sharedObjectsFile

setSharedObjectsFile

public void setSharedObjectsFile(String sharedObjectsFile)

Parameters:

sharedObjectsFile - the sharedObjectsFile to set

setModifiedUser

public void setModifiedUser(String modifiedUser)

Specified by:

setModifiedUser in interface EngineMetaInterface

Parameters:

modifiedUser - The modifiedUser to set.

getModifiedUser

public String getModifiedUser()

Specified by:

getModifiedUser in interface EngineMetaInterface

Returns:

Returns the modifiedUser.

setModifiedDate

public void setModifiedDate(Date modifiedDate)

Specified by:

setModifiedDate in interface EngineMetaInterface

Parameters:

modifiedDate - The modifiedDate to set.

getModifiedDate

public Date getModifiedDate()

Specified by:

getModifiedDate in interface EngineMetaInterface

Returns:

Returns the modifiedDate.

getDescription

public String getDescription()

Specified by:

getDescription in interface org.pentaho.di.repository.RepositoryElementInterface

Returns:

The description of the job

getExtendedDescription

public String getExtendedDescription()

Returns:

The extended description of the job

getJobversion

public String getJobversion()

Returns:

The version of the job

getJobstatus

public int getJobstatus()

Get the status of the job

setDescription

public void setDescription(String description)

Set the description of the job.

Specified by:

setDescription in interface org.pentaho.di.repository.RepositoryElementInterface

Parameters:

description - The new description of the job

setExtendedDescription

public void setExtendedDescription(String extendedDescription)

Set the description of the job.

Parameters:

extendedDescription - The new extended description of the job

setJobversion

public void setJobversion(String jobVersion)

Set the version of the job.

Parameters:

jobVersion - The new version description of the job

setJobstatus

public void setJobstatus(int jobStatus)

Set the status of the job.

Parameters:

jobStatus - The new status description of the job

getCreatedDate

public Date getCreatedDate()

Specified by:

getCreatedDate in interface EngineMetaInterface

Returns:

Returns the createdDate.

setCreatedDate

public void setCreatedDate(Date createdDate)

Specified by:

setCreatedDate in interface EngineMetaInterface

Parameters:

createdDate - The createdDate to set.

setCreatedUser

public void setCreatedUser(String createdUser)

Specified by:

setCreatedUser in interface EngineMetaInterface

Parameters:

createdUser - The createdUser to set.

getCreatedUser

public String getCreatedUser()

Specified by:

getCreatedUser in interface EngineMetaInterface

Returns:

Returns the createdUser.

findJobEntry

public static final JobEntryInterface findJobEntry(List<JobEntryInterface> jobentries,
                                                   org.pentaho.di.repository.ObjectId id_jobentry)

Find a jobentry with a certain ID in a list of job entries.

Parameters:

jobentries - The List of jobentries

id_jobentry - The id of the jobentry

Returns:

The JobEntry object if one was found, null otherwise.

findJobEntryCopy

public static final JobEntryCopy findJobEntryCopy(List<JobEntryCopy> jobcopies,
                                                  org.pentaho.di.repository.ObjectId id_jobentry_copy)

Find a jobentrycopy with a certain ID in a list of job entry copies.

Parameters:

jobcopies - The List of jobentry copies

id_jobentry_copy - The id of the jobentry copy

Returns:

The JobEntryCopy object if one was found, null otherwise.

setInternalKettleVariables

public void setInternalKettleVariables()

Calls setInternalKettleVariables on the default object.

Specified by:

setInternalKettleVariables in interface EngineMetaInterface

setInternalKettleVariables

public void setInternalKettleVariables(org.pentaho.di.core.variables.VariableSpace var)

This method sets various internal kettle variables that can be used by the transformation.

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

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

checkJobEntries

public void checkJobEntries(List<org.pentaho.di.core.CheckResultInterface> remarks,
                            boolean only_selected,
                            org.pentaho.di.core.ProgressMonitorListener monitor)

Check all job entries within the job. Each Job Entry has the opportunity to check their own settings.

Parameters:

remarks - List of CheckResult remarks inserted into by each JobEntry

only_selected - true if you only want to check the selected jobs

monitor - Progress monitor (not presently in use)

getResourceDependencies

public List<ResourceReference> getResourceDependencies()

exportResources

public String exportResources(org.pentaho.di.core.variables.VariableSpace space,
                              Map<String,ResourceDefinition> definitions,
                              ResourceNamingInterface namingInterface,
                              Repository repository)
                       throws org.pentaho.di.core.exception.KettleException

Description copied from interface: ResourceExportInterface

Exports the object to a flat-file system, adding content with filename keys to a set of definitions. The supplied resource naming interface allows the object to name appropriately without worrying about those parts of the implementation specific details.

Specified by:

exportResources in interface ResourceExportInterface

Parameters:

space - The variable space to resolve (environment) variables with.

definitions - The map containing the filenames and content

namingInterface - The resource naming interface allows the object to name appropriately

repository - the repository object to load from

Returns:

The filename for this object. (also contained in the definitions map)

Throws:

org.pentaho.di.core.exception.KettleException - in case something goes wrong during the export

getSlaveServers

public List<SlaveServer> getSlaveServers()

Specified by:

getSlaveServers in interface HasSlaveServersInterface

Returns:

the slaveServer list

setSlaveServers

public void setSlaveServers(List<SlaveServer> slaveServers)

Parameters:

slaveServers - the slaveServers to set

findSlaveServer

public SlaveServer findSlaveServer(String serverString)

Find a slave server using the name

Parameters:

serverString - the name of the slave server

Returns:

the slave server or null if we couldn't spot an approriate entry.

getSlaveServerNames

public String[] getSlaveServerNames()

Returns:

An array list slave server names

renameJobEntryIfNameCollides

public void renameJobEntryIfNameCollides(JobEntryCopy je)

See if the name of the supplied job entry copy doesn't collide with any other job entry copy in the job.

Parameters:

je - The job entry copy to verify the name for.

getSharedObjects

public SharedObjects getSharedObjects()

Returns:

the sharedObjects

setSharedObjects

public void setSharedObjects(SharedObjects sharedObjects)

Parameters:

sharedObjects - the sharedObjects to set

addNameChangedListener

public void addNameChangedListener(NameChangedListener listener)

removeNameChangedListener

public void removeNameChangedListener(NameChangedListener listener)

addFilenameChangedListener

public void addFilenameChangedListener(FilenameChangedListener listener)

removeFilenameChangedListener

public void removeFilenameChangedListener(FilenameChangedListener listener)

activateParameters

public void activateParameters()

Specified by:

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

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

copyParametersFrom

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

Specified by:

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

getJobCopies

public List<JobEntryCopy> getJobCopies()

getNotes

public List<NotePadMeta> getNotes()

getJobhops

public List<JobHopMeta> getJobhops()

getRepositoryElementType

public org.pentaho.di.repository.RepositoryObjectType getRepositoryElementType()

Specified by:

getRepositoryElementType in interface org.pentaho.di.repository.RepositoryElementInterface

getObjectRevision

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

Specified by:

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

Specified by:

getObjectRevision in interface org.pentaho.di.repository.RepositoryElementInterface

setObjectRevision

public void setObjectRevision(org.pentaho.di.repository.ObjectRevision objectRevision)

Specified by:

setObjectRevision in interface org.pentaho.di.repository.RepositoryElementInterface

composeJobEntryInterfaceList

public List<JobEntryInterface> composeJobEntryInterfaceList()

Create a unique list of job entry interfaces

Returns:

getLogChannelId

public String getLogChannelId()

Specified by:

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

getObjectName

public String getObjectName()

Specified by:

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

getObjectCopy

public String getObjectCopy()

Specified by:

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

getObjectType

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

Specified by:

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

getParent

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

Specified by:

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

getLogLevel

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

Specified by:

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

setLogLevel

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

getChannelLogTable

public ChannelLogTable getChannelLogTable()

Returns:

the channelLogTable

setChannelLogTable

public void setChannelLogTable(ChannelLogTable channelLogTable)

Parameters:

channelLogTable - the channelLogTable to set

getJobEntryLogTable

public JobEntryLogTable getJobEntryLogTable()

Returns:

the jobEntryLogTable

setJobEntryLogTable

public void setJobEntryLogTable(JobEntryLogTable jobEntryLogTable)

Parameters:

jobEntryLogTable - the jobEntryLogTable to set

getLogTables

public List<org.pentaho.di.core.logging.LogTableInterface> getLogTables()

canSave

public boolean canSave()

Specified by:

canSave in interface EngineMetaInterface

getContainerObjectId

public String getContainerObjectId()

Specified by:

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

Returns:

the carteObjectId

setCarteObjectId

public void setCarteObjectId(String containerObjectId)

Parameters:

containerObjectId - the execution container Object id to set

getRegistrationDate

public Date getRegistrationDate()

Stub

Specified by:

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

hasRepositoryReferences

public boolean hasRepositoryReferences()

lookupRepositoryReferences

public void lookupRepositoryReferences(Repository repository)
                                throws org.pentaho.di.core.exception.KettleException

Look up the references after import

Parameters:

repository - the repository to reference.

Throws:

org.pentaho.di.core.exception.KettleException

getRepository

public Repository getRepository()

Specified by:

getRepository in interface HasRepositoryInterface

Returns:

the repository

setRepository

public void setRepository(Repository repository)

Specified by:

setRepository in interface HasRepositoryInterface

Parameters:

repository - the repository to set