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, org.pentaho.di.core.AttributesInterface
| Modifier and Type | Field and Description |
|---|---|
boolean[] |
max
List of booleans indicating whether or not to remember the size and position of the different windows...
|
static org.pentaho.di.repository.RepositoryObjectType |
REPOSITORY_ELEMENT_TYPE
A constant specifying the repository element type as a Job.
|
static String |
STRING_SPECIAL
Constant = "SPECIAL"
|
static String |
STRING_SPECIAL_DUMMY
Constant = "DUMMY"
|
static String |
STRING_SPECIAL_ERROR
Constant = "ERROR"
|
static String |
STRING_SPECIAL_OK
Constant = "OK"
|
static String |
STRING_SPECIAL_START
Constant = "START"
|
static int |
TYPE_UNDO_CHANGE
Constant = 1
|
static int |
TYPE_UNDO_DELETE
Constant = 3
|
static int |
TYPE_UNDO_NEW
Constant = 2
|
static int |
TYPE_UNDO_POSITION
Constant = 4
|
static String |
XML_TAG |
| Constructor and Description |
|---|
JobMeta()
Instantiates a new job meta.
|
JobMeta(InputStream inputStream,
Repository rep,
org.pentaho.di.core.gui.OverwritePrompter prompter)
Instantiates a new job meta.
|
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)
Instantiates a new job meta.
|
JobMeta(String fname,
Repository rep,
org.pentaho.di.core.gui.OverwritePrompter prompter)
Instantiates a new job meta.
|
JobMeta(org.pentaho.di.core.variables.VariableSpace parentSpace,
String fname,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
org.pentaho.di.core.gui.OverwritePrompter prompter)
Load the job from the XML file specified.
|
JobMeta(org.pentaho.di.core.variables.VariableSpace parentSpace,
String fname,
Repository rep,
org.pentaho.di.core.gui.OverwritePrompter prompter)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
void |
activateParameters() |
void |
addContentChangedListener(ContentChangedListener listener)
Adds the passed ContentChangedListener to the list of listeners.
|
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()
Adds the defaults.
|
void |
addFilenameChangedListener(FilenameChangedListener listener)
Adds the filename changed listener.
|
void |
addJobEntry(int p,
JobEntryCopy si)
Adds the job entry.
|
void |
addJobEntry(JobEntryCopy je)
Adds the job entry.
|
void |
addJobHop(int p,
JobHopMeta hi)
Adds the job hop.
|
void |
addJobHop(JobHopMeta hi)
Adds the job hop.
|
void |
addNameChangedListener(NameChangedListener listener)
Adds the name changed listener.
|
void |
addNote(int p,
NotePadMeta ni)
Adds the note.
|
void |
addNote(NotePadMeta ni)
Adds the note.
|
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()
Checks whether the job can be saved.
|
void |
checkJobEntries(List<org.pentaho.di.core.CheckResultInterface> remarks,
boolean only_selected,
org.pentaho.di.core.ProgressMonitorListener monitor)
Deprecated.
|
void |
checkJobEntries(List<org.pentaho.di.core.CheckResultInterface> remarks,
boolean only_selected,
org.pentaho.di.core.ProgressMonitorListener monitor,
org.pentaho.di.core.variables.VariableSpace space,
Repository repository,
org.pentaho.metastore.api.IMetaStore metaStore)
Check all job entries within the job.
|
void |
clear()
Clears or reinitializes many of the JobMeta properties.
|
void |
clearChanged()
Clears the different changed flags of the job.
|
void |
clearParameters() |
void |
clearUndo()
Clear undo.
|
Object |
clone()
Clones the job meta-data object.
|
int |
compare(JobMeta j1,
JobMeta j2)
Compares two transformation on name, filename
|
int |
compareTo(JobMeta o)
Compares this job's meta-data to the specified job's meta-data.
|
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)
Count entries.
|
static JobEntryCopy |
createDummyEntry()
Creates the dummy entry.
|
static JobEntryCopy |
createStartEntry()
Creates the start entry.
|
String |
environmentSubstitute(String aString) |
String[] |
environmentSubstitute(String[] aString) |
boolean |
equals(Object obj)
Checks whether this job's meta-data object is equal to the specified object.
|
void |
eraseParameters() |
String |
exportResources(org.pentaho.di.core.variables.VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface namingInterface,
Repository repository,
org.pentaho.metastore.api.IMetaStore metaStore)
Exports the object to a flat-file system, adding content with filename keys to a set of definitions.
|
String |
fieldSubstitute(String aString,
org.pentaho.di.core.row.RowMetaInterface rowMeta,
Object[] rowData) |
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)
Find job entry.
|
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)
Find job hop.
|
JobHopMeta |
findJobHop(JobEntryCopy from,
JobEntryCopy to,
boolean includeDisabled)
Find job hop.
|
JobHopMeta |
findJobHop(String name)
Find job hop.
|
JobHopMeta |
findJobHopFrom(JobEntryCopy jge)
Find job hop from.
|
JobHopMeta |
findJobHopTo(JobEntryCopy jge)
Find job hop to.
|
int |
findMaxNr(String name)
Find max nr.
|
JobEntryCopy |
findNextJobEntry(JobEntryCopy from,
int cnt)
Find next job entry.
|
int |
findNrNextJobEntries(JobEntryCopy from)
Find nr next job entries.
|
int |
findNrPrevJobEntries(JobEntryCopy from)
Find nr prev job entries.
|
int |
findNrPrevJobEntries(JobEntryCopy to,
boolean info)
Find nr prev job entries.
|
JobEntryCopy |
findPrevJobEntry(JobEntryCopy to,
int nr)
Find prev job entry.
|
JobEntryCopy |
findPrevJobEntry(JobEntryCopy to,
int nr,
boolean info)
Find prev job entry.
|
SlaveServer |
findSlaveServer(String serverString)
Find a slave server using the name
|
JobEntryCopy |
findStart()
Find start.
|
int |
findUnusedNr(String name)
Find unused nr.
|
JobEntryCopy[] |
getAllJobGraphEntries(String name)
Gets the all job graph entries.
|
JobHopMeta[] |
getAllJobHopsUsing(String name)
Gets the all job hops using.
|
String |
getAlternativeJobentryName(String entryname)
Proposes an alternative job entry name when the original already
exists...
|
String[] |
getArguments()
Deprecated.
Moved to the Job class
|
String |
getAttribute(String groupName,
String key) |
Map<String,String> |
getAttributes(String groupName) |
Map<String,Map<String,String>> |
getAttributesMap() |
boolean |
getBooleanValueOfVariable(String variableName,
boolean defaultValue) |
ChannelLogTable |
getChannelLogTable()
Gets the channel log table for the job.
|
String |
getContainerObjectId()
Gets the container object id.
|
Date |
getCreatedDate()
Gets the date the job was created.
|
String |
getCreatedUser()
Gets the user by whom the job was created.
|
org.pentaho.di.core.database.DatabaseMeta |
getDatabase(int i)
Retrieves a database connection information a a certain location.
|
String[] |
getDatabaseNames()
Gets the database names.
|
List<org.pentaho.di.core.database.DatabaseMeta> |
getDatabases()
Returns a list of the databases.
|
String |
getDefaultExtension()
Gets the default extension for a job.
|
String |
getDescription()
Gets the description of the job.
|
JobEntryCopy |
getDummy()
Gets the dummy.
|
int[] |
getEntryIndexes(List<JobEntryCopy> entries)
Gets the entry indexes.
|
String |
getExtendedDescription()
Gets the extended description of the job.
|
List<LogTableInterface> |
getExtraLogTables() |
String |
getFilename()
Gets the filename.
|
String |
getFileType()
Gets the file type.
|
String[] |
getFilterExtensions()
Gets the job filter extensions.
|
String[] |
getFilterNames()
Gets the job filter names.
|
List<JobEntryCopy> |
getJobCopies()
Gets the job copies.
|
JobEntryCopy |
getJobEntry(int i)
Gets the job entry.
|
JobEntryCopy |
getJobEntryCopy(int x,
int y,
int iconsize)
Gets the job entry copy.
|
JobEntryLogTable |
getJobEntryLogTable()
Gets the job entry log table.
|
JobHopMeta |
getJobHop(int i)
Gets the job hop.
|
List<JobHopMeta> |
getJobhops()
Gets the jobhops.
|
JobLogTable |
getJobLogTable()
Gets the job log table.
|
int |
getJobstatus()
Gets the status of the job.
|
String |
getJobversion()
Gets the version of the job.
|
String |
getLogChannelId() |
org.pentaho.di.core.logging.LogLevel |
getLogLevel() |
List<LogTableInterface> |
getLogTables()
Gets the log tables.
|
org.pentaho.di.core.gui.Point |
getMaximum()
Gets the maximum.
|
int |
getMaxUndo()
Get the maximum number of undo operations possible
|
org.pentaho.metastore.api.IMetaStore |
getMetaStore() |
org.pentaho.di.core.gui.Point |
getMinimum()
Get the minimum point on the canvas of a job
|
Date |
getModifiedDate()
Gets the date the job was last modified.
|
String |
getModifiedUser()
Gets the user who last modified the job.
|
String |
getName()
Gets the name.
|
NotePadMeta |
getNote(int i)
Gets the note.
|
NotePadMeta |
getNote(int x,
int y)
Gets the note.
|
int[] |
getNoteIndexes(List<NotePadMeta> notes)
Get an array of the locations of an array of notes
|
List<NotePadMeta> |
getNotes()
Gets the notes.
|
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()
Gets the registration date for the transformation.
|
Repository |
getRepository()
Gets the repository.
|
org.pentaho.di.repository.RepositoryDirectoryInterface |
getRepositoryDirectory()
Gets the directory.
|
org.pentaho.di.repository.RepositoryObjectType |
getRepositoryElementType() |
List<ResourceReference> |
getResourceDependencies()
Gets the resource dependencies.
|
List<JobEntryCopy> |
getSelectedEntries()
Gets the selected entries.
|
org.pentaho.di.core.gui.Point[] |
getSelectedLocations()
Gets the selected locations.
|
org.pentaho.di.core.gui.Point[] |
getSelectedNoteLocations()
Get all the selected note locations
|
List<NotePadMeta> |
getSelectedNotes()
Gets a list of all selected notes.
|
SharedObjects |
getSharedObjects()
Gets the shared objects.
|
String |
getSharedObjectsFile()
Gets the shared objects file.
|
String[] |
getSlaveServerNames()
Gets an array of slave server names.
|
List<SlaveServer> |
getSlaveServers()
Gets a list of slave servers.
|
List<org.pentaho.di.core.SQLStatement> |
getSQLStatements(Repository repository,
org.pentaho.metastore.api.IMetaStore metaStore,
org.pentaho.di.core.ProgressMonitorListener monitor)
Builds a list of all the SQL statements that this transformation needs in
order to work properly.
|
List<org.pentaho.di.core.SQLStatement> |
getSQLStatements(Repository repository,
org.pentaho.di.core.ProgressMonitorListener monitor) |
JobEntryCopy |
getStart()
Gets the start.
|
List<StringSearchResult> |
getStringList(boolean searchSteps,
boolean searchDatabases,
boolean searchNotes)
Get a list of all the strings used in this job.
|
int |
getUndoSize()
Gets the undo size.
|
List<String> |
getUsedVariables()
Gets the used variables.
|
String |
getVariable(String variableName) |
String |
getVariable(String variableName,
String defaultValue) |
String |
getXML()
Gets the XML representation.
|
boolean |
hasChanged()
Checks whether or not this has changed.
|
boolean |
hasLoop(JobEntryCopy entry)
Checks for loop.
|
boolean |
hasLoop(JobEntryCopy entry,
JobEntryCopy lookup)
Checks for loop.
|
boolean |
hasRepositoryReferences()
Checks whether the job has repository references.
|
boolean |
haveConnectionsChanged()
Checks whether or not the connections have changed.
|
boolean |
haveJobEntriesChanged()
Have job entries changed.
|
boolean |
haveJobHopsChanged()
Have job hops changed.
|
boolean |
haveNotesChanged()
Have notes changed.
|
int |
indexOfDatabase(org.pentaho.di.core.database.DatabaseMeta di)
Find the location of database
|
int |
indexOfJobEntry(JobEntryCopy ge)
Index of job entry.
|
int |
indexOfJobHop(JobHopMeta he)
Index of job hop.
|
int |
indexOfNote(NotePadMeta ni)
Index of note.
|
void |
initializeVariablesFrom(org.pentaho.di.core.variables.VariableSpace parent) |
void |
injectVariables(Map<String,String> prop) |
boolean |
isBatchIdPassed()
Gets the boolean value of batch id passed.
|
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)
Checks if is entry used in hops.
|
boolean |
isFileReference()
Checks if is file reference.
|
static boolean |
isFileReference(String fileName,
String transName)
Checks if is file reference.
|
boolean |
isForcingSeparateLogging() |
boolean |
isGatheringMetrics()
Returns whether or not the job is gathering metrics.
|
boolean |
isRepReference()
Checks if is rep reference.
|
static boolean |
isRepReference(String fileName,
String transName)
Checks if is rep reference.
|
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)
Load xml.
|
void |
loadXML(Node jobnode,
String fname,
Repository rep,
boolean ignoreRepositorySharedObjects,
org.pentaho.di.core.gui.OverwritePrompter prompter)
Deprecated.
|
void |
loadXML(Node jobnode,
String fname,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
boolean ignoreRepositorySharedObjects,
org.pentaho.di.core.gui.OverwritePrompter prompter)
Load a block of XML from an DOM node.
|
void |
loadXML(Node jobnode,
String fname,
Repository rep,
org.pentaho.di.core.gui.OverwritePrompter prompter)
Load xml.
|
void |
lookupRepositoryReferences(Repository repository)
Look up the references after import
|
void |
lowerNote(int p)
Lower note.
|
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()
Nr job entries.
|
int |
nrJobHops()
Nr job hops.
|
int |
nrNotes()
Nr notes.
|
TransAction |
previousUndo()
Get the previous undo operation and change the undo pointer
|
void |
raiseNote(int p)
Raise note.
|
SharedObjects |
readSharedObjects()
Read shared objects.
|
Object |
realClone(boolean doClear)
Perform a real clone of the job meta-data object, including cloning all lists
and copying all values.
|
void |
removeContentChangedListener(ContentChangedListener listener)
Removes the passed ContentChangedListener from the list of listeners.
|
void |
removeDatabase(int i)
Removes a database from the transformation on a certain location.
|
void |
removeFilenameChangedListener(FilenameChangedListener listener)
Removes the filename changed listener.
|
void |
removeJobEntry(int i)
Removes the job entry.
|
void |
removeJobHop(int i)
Removes the job hop.
|
void |
removeNameChangedListener(NameChangedListener listener)
Removes the name changed listener.
|
void |
removeNote(int i)
Removes the note.
|
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 |
saveMetaStoreObjects(Repository repository,
org.pentaho.metastore.api.IMetaStore metaStore)
This method needs to be called to store those objects which are used and referenced
in the job metadata but not saved in the serialization.
|
void |
saveSharedObjects()
Saves shared objects, including databases, steps, partition schemas, slave servers, and
cluster schemas, to a file.
|
void |
selectAll()
Select all.
|
void |
setArguments(String[] arguments)
Deprecated.
moved to the job class
|
void |
setAttribute(String groupName,
String key,
String value) |
void |
setAttributes(String groupName,
Map<String,String> attributes) |
void |
setAttributesMap(Map<String,Map<String,String>> attributesMap) |
void |
setBatchIdPassed(boolean batchIdPassed)
Sets the batch id passed.
|
void |
setCarteObjectId(String containerObjectId)
Sets the carte object id.
|
void |
setChanged(boolean ch)
Sets whether or not this has changed.
|
void |
setChannelLogTable(ChannelLogTable channelLogTable)
Sets the channel log table for the job.
|
void |
setCreatedDate(Date createdDate)
Sets the date the transformation was created.
|
void |
setCreatedUser(String createdUser)
Sets the user by whom this was created.
|
void |
setDatabases(List<org.pentaho.di.core.database.DatabaseMeta> databases)
Sets the databases.
|
void |
setDescription(String description)
Set the description of the job.
|
void |
setExtendedDescription(String extendedDescription)
Set the description of the job.
|
void |
setExtraLogTables(List<LogTableInterface> extraLogTables) |
void |
setFilename(String newFilename)
Set the filename of the job
|
void |
setForcingSeparateLogging(boolean forcingSeparateLogging) |
void |
setGatheringMetrics(boolean gatheringMetrics)
Sets whether or not the job is gathering metrics.
|
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)
Sets the job entry.
|
void |
setJobEntryLogTable(JobEntryLogTable jobEntryLogTable)
Sets the job entry log table.
|
void |
setJobLogTable(JobLogTable jobLogTable)
Sets the job log table.
|
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)
Sets the log level.
|
void |
setMaxUndo(int mu)
Sets the maximum number of undo operations that are allowed.
|
void |
setMetaStore(org.pentaho.metastore.api.IMetaStore metaStore) |
void |
setModifiedDate(Date modifiedDate)
Sets the date the job was modified.
|
void |
setModifiedUser(String modifiedUser)
Sets the user who last modified the job.
|
void |
setName(String newName)
Set the name of the job.
|
void |
setObjectId(org.pentaho.di.repository.ObjectId objectId)
Set the database ID for this in the repository.
|
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)
Sets the repository.
|
void |
setRepositoryDirectory(org.pentaho.di.repository.RepositoryDirectoryInterface directory)
Sets the directory.
|
void |
setSharedObjects(SharedObjects sharedObjects)
Sets the shared objects.
|
void |
setSharedObjectsFile(String sharedObjectsFile)
Sets the shared objects file.
|
void |
setSlaveServers(List<SlaveServer> slaveServers)
Sets the slave servers.
|
void |
setVariable(String variableName,
String variableValue) |
void |
shareVariablesWith(org.pentaho.di.core.variables.VariableSpace space) |
String |
toString()
Gets a textual representation of the job.
|
void |
unselectAll()
Unselect all.
|
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
|
addObserver, deleteObserver, notifyObservers, setChangedpublic static final String XML_TAG
public static final org.pentaho.di.repository.RepositoryObjectType REPOSITORY_ELEMENT_TYPE
public static final int TYPE_UNDO_CHANGE
public static final int TYPE_UNDO_NEW
public static final int TYPE_UNDO_DELETE
public static final int TYPE_UNDO_POSITION
public static final String STRING_SPECIAL
public static final String STRING_SPECIAL_START
public static final String STRING_SPECIAL_DUMMY
public static final String STRING_SPECIAL_OK
public static final String STRING_SPECIAL_ERROR
public boolean[] max
public JobMeta()
public JobMeta(String fname, Repository rep) throws org.pentaho.di.core.exception.KettleXMLException
fname - the fnamerep - the reporg.pentaho.di.core.exception.KettleXMLException - the kettle xml exceptionpublic JobMeta(String fname, Repository rep, org.pentaho.di.core.gui.OverwritePrompter prompter) throws org.pentaho.di.core.exception.KettleXMLException
fname - the fnamerep - the repprompter - the prompterorg.pentaho.di.core.exception.KettleXMLException - the kettle xml exception@Deprecated 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
log - the logging channelfname - The filename to load as a jobrep - The repository to bind againt, null if there is no repository
available.org.pentaho.di.core.exception.KettleXMLExceptionpublic JobMeta(org.pentaho.di.core.variables.VariableSpace parentSpace,
String fname,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
org.pentaho.di.core.gui.OverwritePrompter prompter)
throws org.pentaho.di.core.exception.KettleXMLException
log - the logging channelfname - The filename to load as a jobrep - The repository to bind againt, null if there is no repository
available.org.pentaho.di.core.exception.KettleXMLExceptionpublic JobMeta(InputStream inputStream, Repository rep, org.pentaho.di.core.gui.OverwritePrompter prompter) throws org.pentaho.di.core.exception.KettleXMLException
inputStream - the input streamrep - the repprompter - the prompterorg.pentaho.di.core.exception.KettleXMLException - the kettle xml exceptionpublic JobMeta(Node jobnode, Repository rep, org.pentaho.di.core.gui.OverwritePrompter prompter) throws org.pentaho.di.core.exception.KettleXMLException
jobnode - The node to load fromrep - The reference to a repository to load additional information fromprompter - The prompter to use in case a shared object gets overwrittenorg.pentaho.di.core.exception.KettleXMLExceptionpublic JobMeta(Node jobnode, Repository rep, boolean ignoreRepositorySharedObjects, org.pentaho.di.core.gui.OverwritePrompter prompter) throws org.pentaho.di.core.exception.KettleXMLException
jobnode - The node to load fromrep - The reference to a repository to load additional information fromignoreRepositorySharedObjects - Do not load shared objects, handled separatelyprompter - The prompter to use in case a shared object gets overwrittenorg.pentaho.di.core.exception.KettleXMLExceptionpublic org.pentaho.di.repository.ObjectId getObjectId()
getObjectId in interface org.pentaho.di.core.logging.LoggingObjectInterfacegetObjectId in interface org.pentaho.di.repository.RepositoryElementInterfacegetObjectId in interface org.pentaho.di.repository.RepositoryObjectInterfacepublic void setObjectId(org.pentaho.di.repository.ObjectId objectId)
EngineMetaInterfacesetObjectId in interface EngineMetaInterfacesetObjectId in interface org.pentaho.di.repository.RepositoryElementInterfaceobjectId - the database ID for this in the repositorypublic void clear()
public void addDefaults()
public static final JobEntryCopy createStartEntry()
public static final JobEntryCopy createDummyEntry()
public JobEntryCopy getStart()
public JobEntryCopy getDummy()
public int compareTo(JobMeta o)
compareTo in interface Comparable<JobMeta>o - the ocompare(JobMeta, JobMeta),
Comparable.compareTo(java.lang.Object)public boolean equals(Object obj)
equals in class Objectobj - the objcompare(JobMeta, JobMeta),
Object.equals(java.lang.Object)public Object clone()
clone in class ObjectObject.clone()public Object realClone(boolean doClear)
doClear - Whether to clear all of the clone's data before copying from the source objectpublic String getName()
EngineMetaInterfacegetName in interface EngineMetaInterfacegetName in interface org.pentaho.di.repository.RepositoryElementInterfacegetName in interface org.pentaho.di.repository.RepositoryObjectInterfacepublic void setName(String newName)
setName in interface org.pentaho.di.repository.RepositoryElementInterfacenewName - The new name of the jobpublic void nameFromFilename()
nameFromFilename in interface EngineMetaInterfacepublic org.pentaho.di.repository.RepositoryDirectoryInterface getRepositoryDirectory()
getRepositoryDirectory in interface EngineMetaInterfacegetRepositoryDirectory in interface org.pentaho.di.core.logging.LoggingObjectInterfacegetRepositoryDirectory in interface org.pentaho.di.repository.RepositoryElementInterfacepublic void setRepositoryDirectory(org.pentaho.di.repository.RepositoryDirectoryInterface directory)
setRepositoryDirectory in interface org.pentaho.di.repository.RepositoryElementInterfacedirectory - The directory to set.public String getFilename()
getFilename in interface EngineMetaInterfacegetFilename in interface org.pentaho.di.core.logging.LoggingObjectInterfaceEngineMetaInterface.getFilename()public void setFilename(String newFilename)
setFilename in interface EngineMetaInterfacenewFilename - The new filename of the jobpublic JobLogTable getJobLogTable()
public void setJobLogTable(JobLogTable jobLogTable)
jobLogTable - the new job log tablepublic List<org.pentaho.di.core.database.DatabaseMeta> getDatabases()
getDatabases in interface HasDatabasesInterfacepublic String[] getDatabaseNames()
public void setDatabases(List<org.pentaho.di.core.database.DatabaseMeta> databases)
setDatabases in interface HasDatabasesInterfacedatabases - The databases to set.public void setChanged(boolean ch)
ChangedFlagsetChanged in interface ChangedFlagInterfacesetChanged in class ChangedFlagpublic void clearChanged()
clearChanged in interface ChangedFlagInterfaceclearChanged in interface EngineMetaInterfaceclearChanged in class ChangedFlagpublic boolean hasChanged()
ChangedFlaghasChanged in interface ChangedFlagInterfacehasChanged in class ChangedFlagpublic boolean isDatabaseConnectionUsed(org.pentaho.di.core.database.DatabaseMeta databaseMeta)
databaseMeta - The connection to checkpublic String getFileType()
EngineMetaInterfacegetFileType in interface EngineMetaInterfacepublic String[] getFilterNames()
getFilterNames in interface EngineMetaInterfaceEngineMetaInterface.getFilterNames()public String[] getFilterExtensions()
Const.STRING_JOB_FILTER_EXTgetFilterExtensions in interface EngineMetaInterfaceEngineMetaInterface.getFilterExtensions()public String getDefaultExtension()
Const.STRING_JOB_DEFAULT_EXTgetDefaultExtension in interface EngineMetaInterfaceEngineMetaInterface.getDefaultExtension()public String getXML()
EngineMetaInterfacegetXML in interface EngineMetaInterfacegetXML in interface org.pentaho.di.core.xml.XMLInterfaceXMLInterface.getXML()public boolean isRepReference()
public boolean isFileReference()
public static boolean isRepReference(String fileName, String transName)
fileName - the file nametransName - the trans namepublic static boolean isFileReference(String fileName, String transName)
fileName - the file nametransName - the trans namepublic void loadXML(Node jobnode, Repository rep, org.pentaho.di.core.gui.OverwritePrompter prompter) throws org.pentaho.di.core.exception.KettleXMLException
jobnode - the jobnoderep - the repprompter - the prompterorg.pentaho.di.core.exception.KettleXMLException - the kettle xml exceptionpublic void loadXML(Node jobnode, String fname, Repository rep, org.pentaho.di.core.gui.OverwritePrompter prompter) throws org.pentaho.di.core.exception.KettleXMLException
jobnode - the jobnodefname - The filenamerep - the repprompter - the prompterorg.pentaho.di.core.exception.KettleXMLException - the kettle xml exceptionpublic void loadXML(Node jobnode, Repository rep, boolean ignoreRepositorySharedObjects, org.pentaho.di.core.gui.OverwritePrompter prompter) throws org.pentaho.di.core.exception.KettleXMLException
jobnode - The node to load fromrep - The reference to a repository to load additional information fromignoreRepositorySharedObjects - Do not load shared objects, handled separatelyprompter - The prompter to use in case a shared object gets overwrittenorg.pentaho.di.core.exception.KettleXMLException@Deprecated public void loadXML(Node jobnode, String fname, Repository rep, boolean ignoreRepositorySharedObjects, org.pentaho.di.core.gui.OverwritePrompter prompter) throws org.pentaho.di.core.exception.KettleXMLException
jobnode - The node to load fromfname - The filenamerep - The reference to a repository to load additional information fromignoreRepositorySharedObjects - Do not load shared objects, handled separatelyprompter - The prompter to use in case a shared object gets overwrittenorg.pentaho.di.core.exception.KettleXMLExceptionpublic void loadXML(Node jobnode, String fname, Repository rep, org.pentaho.metastore.api.IMetaStore metaStore, boolean ignoreRepositorySharedObjects, org.pentaho.di.core.gui.OverwritePrompter prompter) throws org.pentaho.di.core.exception.KettleXMLException
jobnode - The node to load fromfname - The filenamerep - The reference to a repository to load additional information frommetaStore - the MetaStore to useignoreRepositorySharedObjects - Do not load shared objects, handled separatelyprompter - The prompter to use in case a shared object gets overwrittenorg.pentaho.di.core.exception.KettleXMLExceptionpublic SharedObjects readSharedObjects() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException - the kettle exceptionpublic void saveSharedObjects()
throws org.pentaho.di.core.exception.KettleException
EngineMetaInterfacesaveSharedObjects in interface EngineMetaInterfaceorg.pentaho.di.core.exception.KettleExceptionpublic org.pentaho.di.core.database.DatabaseMeta findDatabase(String name)
findDatabase in interface HasDatabasesInterfacename - The database name to look forpublic JobEntryCopy getJobEntryCopy(int x, int y, int iconsize)
x - the xy - the yiconsize - the iconsizepublic int nrJobEntries()
public int nrJobHops()
public int nrNotes()
public int nrDatabases()
HasDatabasesInterfacenrDatabases in interface HasDatabasesInterfacepublic JobHopMeta getJobHop(int i)
i - the ipublic JobEntryCopy getJobEntry(int i)
i - the ipublic NotePadMeta getNote(int i)
i - the ipublic org.pentaho.di.core.database.DatabaseMeta getDatabase(int i)
HasDatabasesInterfacegetDatabase in interface HasDatabasesInterfacei - The database number.public void addJobEntry(JobEntryCopy je)
je - the jepublic void addJobHop(JobHopMeta hi)
hi - the hipublic void addNote(NotePadMeta ni)
ni - the nipublic void addDatabase(org.pentaho.di.core.database.DatabaseMeta ci)
HasDatabasesInterfaceaddDatabase in interface HasDatabasesInterfaceci - The database connection information.public void addJobEntry(int p,
JobEntryCopy si)
p - the psi - the sipublic void addJobHop(int p,
JobHopMeta hi)
p - the phi - the hipublic void addNote(int p,
NotePadMeta ni)
p - the pni - the nipublic void addDatabase(int p,
org.pentaho.di.core.database.DatabaseMeta ci)
HasDatabasesInterfaceaddDatabase in interface HasDatabasesInterfacep - The locationci - The database connection information.public void addOrReplaceDatabase(org.pentaho.di.core.database.DatabaseMeta databaseMeta)
HasDatabasesInterfaceaddOrReplaceDatabase in interface HasDatabasesInterfacedatabaseMeta - The database connection information.public void addOrReplaceSlaveServer(SlaveServer slaveServer)
slaveServer - The slave server to be added.public void removeJobEntry(int i)
i - the ipublic void removeJobHop(int i)
i - the ipublic void removeNote(int i)
i - the ipublic void raiseNote(int p)
p - the ppublic void lowerNote(int p)
p - the ppublic void removeDatabase(int i)
HasDatabasesInterfaceremoveDatabase in interface HasDatabasesInterfacei - The locationpublic int indexOfJobHop(JobHopMeta he)
he - the hepublic int indexOfNote(NotePadMeta ni)
ni - the nipublic int indexOfJobEntry(JobEntryCopy ge)
ge - the gepublic int indexOfDatabase(org.pentaho.di.core.database.DatabaseMeta di)
HasDatabasesInterfaceindexOfDatabase in interface HasDatabasesInterfacedi - The database queriedpublic void setJobEntry(int idx,
JobEntryCopy jec)
idx - the idxjec - the jecpublic JobEntryCopy findJobEntry(String name, int nr, boolean searchHiddenToo)
name - The name of the job entry copynr - The number of the job entry copypublic JobEntryCopy findJobEntry(String full_name_nr)
full_name_nr - the full_name_nrpublic JobHopMeta findJobHop(String name)
name - the namepublic JobHopMeta findJobHopFrom(JobEntryCopy jge)
jge - the jgepublic JobHopMeta findJobHop(JobEntryCopy from, JobEntryCopy to)
from - the fromto - the topublic JobHopMeta findJobHop(JobEntryCopy from, JobEntryCopy to, boolean includeDisabled)
from - the fromto - the toincludeDisabled - the include disabledpublic JobHopMeta findJobHopTo(JobEntryCopy jge)
jge - the jgepublic int findNrPrevJobEntries(JobEntryCopy from)
from - the frompublic JobEntryCopy findPrevJobEntry(JobEntryCopy to, int nr)
to - the tonr - the nrpublic int findNrPrevJobEntries(JobEntryCopy to, boolean info)
to - the toinfo - the infopublic JobEntryCopy findPrevJobEntry(JobEntryCopy to, int nr, boolean info)
to - the tonr - the nrinfo - the infopublic int findNrNextJobEntries(JobEntryCopy from)
from - the frompublic JobEntryCopy findNextJobEntry(JobEntryCopy from, int cnt)
from - the fromcnt - the cntpublic boolean hasLoop(JobEntryCopy entry)
entry - the entrypublic boolean hasLoop(JobEntryCopy entry, JobEntryCopy lookup)
entry - the entrylookup - the lookuppublic boolean isEntryUsedInHops(JobEntryCopy jge)
jge - the jgepublic int countEntries(String name)
name - the namepublic int findUnusedNr(String name)
name - the namepublic int findMaxNr(String name)
name - the namepublic String getAlternativeJobentryName(String entryname)
entryname - The job entry name to find an alternative for..public JobEntryCopy[] getAllJobGraphEntries(String name)
name - the namepublic JobHopMeta[] getAllJobHopsUsing(String name)
name - the namepublic NotePadMeta getNote(int x, int y)
x - the xy - the ypublic void selectAll()
public void unselectAll()
public int getMaxUndo()
UndoInterfacegetMaxUndo in interface UndoInterfacepublic void setMaxUndo(int mu)
UndoInterfacesetMaxUndo in interface UndoInterfacemu - The maximum number of undo operations that are allowed.public int getUndoSize()
public void clearUndo()
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)
UndoInterfaceaddUndo in interface UndoInterfacefrom - array of objects representing the old stateto - array of objectes representing the new statepos - An array of object locationsprev - An array of points representing the old positionscurr - An array of points representing the new positionstype_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.public TransAction previousUndo()
UndoInterfacepreviousUndo in interface UndoInterfacepublic TransAction viewThisUndo()
viewThisUndo in interface UndoInterfacepublic TransAction viewPreviousUndo()
UndoInterfaceviewPreviousUndo in interface UndoInterfacepublic TransAction nextUndo()
UndoInterfacenextUndo in interface UndoInterfacepublic TransAction viewNextUndo()
UndoInterfaceviewNextUndo in interface UndoInterfacepublic org.pentaho.di.core.gui.Point getMaximum()
public org.pentaho.di.core.gui.Point getMinimum()
public org.pentaho.di.core.gui.Point[] getSelectedLocations()
public org.pentaho.di.core.gui.Point[] getSelectedNoteLocations()
public List<JobEntryCopy> getSelectedEntries()
public List<NotePadMeta> getSelectedNotes()
public int[] getEntryIndexes(List<JobEntryCopy> entries)
entries - the entriespublic int[] getNoteIndexes(List<NotePadMeta> notes)
notes - An array of notespublic JobEntryCopy findStart()
public String toString()
public boolean isBatchIdPassed()
public void setBatchIdPassed(boolean batchIdPassed)
batchIdPassed - The batchIdPassed to set.public List<org.pentaho.di.core.SQLStatement> getSQLStatements(Repository repository, org.pentaho.di.core.ProgressMonitorListener monitor) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleExceptionpublic List<org.pentaho.di.core.SQLStatement> getSQLStatements(Repository repository, org.pentaho.metastore.api.IMetaStore metaStore, org.pentaho.di.core.ProgressMonitorListener monitor) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException@Deprecated public String[] getArguments()
@Deprecated public void setArguments(String[] arguments)
arguments - The arguments to set.public List<StringSearchResult> getStringList(boolean searchSteps, boolean searchDatabases, boolean searchNotes)
public List<String> getUsedVariables()
public boolean haveConnectionsChanged()
HasDatabasesInterfacehaveConnectionsChanged in interface HasDatabasesInterfacepublic boolean haveJobEntriesChanged()
public boolean haveJobHopsChanged()
public boolean haveNotesChanged()
public String getSharedObjectsFile()
public void setSharedObjectsFile(String sharedObjectsFile)
sharedObjectsFile - the sharedObjectsFile to setpublic void setModifiedUser(String modifiedUser)
setModifiedUser in interface EngineMetaInterfacemodifiedUser - The modifiedUser to set.public String getModifiedUser()
getModifiedUser in interface EngineMetaInterfacepublic void setModifiedDate(Date modifiedDate)
setModifiedDate in interface EngineMetaInterfacemodifiedDate - The modifiedDate to set.public Date getModifiedDate()
getModifiedDate in interface EngineMetaInterfacepublic String getDescription()
getDescription in interface org.pentaho.di.repository.RepositoryElementInterfacepublic String getExtendedDescription()
public String getJobversion()
public int getJobstatus()
public void setDescription(String description)
setDescription in interface org.pentaho.di.repository.RepositoryElementInterfacedescription - The new description of the jobpublic void setExtendedDescription(String extendedDescription)
extendedDescription - The new extended description of the jobpublic void setJobversion(String jobVersion)
jobVersion - The new version description of the jobpublic void setJobstatus(int jobStatus)
jobStatus - The new status description of the jobpublic Date getCreatedDate()
getCreatedDate in interface EngineMetaInterfacepublic void setCreatedDate(Date createdDate)
EngineMetaInterfacesetCreatedDate in interface EngineMetaInterfacecreatedDate - The createdDate to set.public void setCreatedUser(String createdUser)
EngineMetaInterfacesetCreatedUser in interface EngineMetaInterfacecreatedUser - The createdUser to set.public String getCreatedUser()
getCreatedUser in interface EngineMetaInterfacepublic static final JobEntryInterface findJobEntry(List<JobEntryInterface> jobentries, org.pentaho.di.repository.ObjectId id_jobentry)
jobentries - The List of jobentriesid_jobentry - The id of the jobentrypublic static final JobEntryCopy findJobEntryCopy(List<JobEntryCopy> jobcopies, org.pentaho.di.repository.ObjectId id_jobentry_copy)
jobcopies - The List of jobentry copiesid_jobentry_copy - The id of the jobentry copypublic void setInternalKettleVariables()
setInternalKettleVariables in interface EngineMetaInterfacepublic void setInternalKettleVariables(org.pentaho.di.core.variables.VariableSpace var)
public void copyVariablesFrom(org.pentaho.di.core.variables.VariableSpace space)
copyVariablesFrom in interface org.pentaho.di.core.variables.VariableSpacepublic String environmentSubstitute(String aString)
environmentSubstitute in interface org.pentaho.di.core.variables.VariableSpacepublic String[] environmentSubstitute(String[] aString)
environmentSubstitute in interface org.pentaho.di.core.variables.VariableSpacepublic String fieldSubstitute(String aString, org.pentaho.di.core.row.RowMetaInterface rowMeta, Object[] rowData) throws org.pentaho.di.core.exception.KettleValueException
fieldSubstitute in interface org.pentaho.di.core.variables.VariableSpaceorg.pentaho.di.core.exception.KettleValueExceptionpublic org.pentaho.di.core.variables.VariableSpace getParentVariableSpace()
getParentVariableSpace in interface org.pentaho.di.core.variables.VariableSpacepublic void setParentVariableSpace(org.pentaho.di.core.variables.VariableSpace parent)
setParentVariableSpace in interface org.pentaho.di.core.variables.VariableSpacepublic String getVariable(String variableName, String defaultValue)
getVariable in interface org.pentaho.di.core.variables.VariableSpacepublic String getVariable(String variableName)
getVariable in interface org.pentaho.di.core.variables.VariableSpacepublic boolean getBooleanValueOfVariable(String variableName, boolean defaultValue)
getBooleanValueOfVariable in interface org.pentaho.di.core.variables.VariableSpacepublic void initializeVariablesFrom(org.pentaho.di.core.variables.VariableSpace parent)
initializeVariablesFrom in interface org.pentaho.di.core.variables.VariableSpacepublic String[] listVariables()
listVariables in interface org.pentaho.di.core.variables.VariableSpacepublic void setVariable(String variableName, String variableValue)
setVariable in interface org.pentaho.di.core.variables.VariableSpacepublic void shareVariablesWith(org.pentaho.di.core.variables.VariableSpace space)
shareVariablesWith in interface org.pentaho.di.core.variables.VariableSpacepublic void injectVariables(Map<String,String> prop)
injectVariables in interface org.pentaho.di.core.variables.VariableSpace@Deprecated public void checkJobEntries(List<org.pentaho.di.core.CheckResultInterface> remarks, boolean only_selected, org.pentaho.di.core.ProgressMonitorListener monitor)
public void checkJobEntries(List<org.pentaho.di.core.CheckResultInterface> remarks, boolean only_selected, org.pentaho.di.core.ProgressMonitorListener monitor, org.pentaho.di.core.variables.VariableSpace space, Repository repository, org.pentaho.metastore.api.IMetaStore metaStore)
remarks - List of CheckResult remarks inserted into by each JobEntryonly_selected - true if you only want to check the selected jobsmonitor - Progress monitor (not presently in use)public List<ResourceReference> getResourceDependencies()
public String exportResources(org.pentaho.di.core.variables.VariableSpace space, Map<String,ResourceDefinition> definitions, ResourceNamingInterface namingInterface, Repository repository, org.pentaho.metastore.api.IMetaStore metaStore) throws org.pentaho.di.core.exception.KettleException
ResourceExportInterfaceexportResources in interface ResourceExportInterfacespace - The variable space to resolve (environment) variables with.definitions - The map containing the filenames and contentnamingInterface - The resource naming interface allows the object to name appropriatelyrepository - the repository object to load frommetaStore - the central metastore to load non-kettle specific metadata fromorg.pentaho.di.core.exception.KettleException - in case something goes wrong during the exportpublic List<SlaveServer> getSlaveServers()
getSlaveServers in interface HasSlaveServersInterfacepublic void setSlaveServers(List<SlaveServer> slaveServers)
slaveServers - the slaveServers to setpublic SlaveServer findSlaveServer(String serverString)
serverString - the name of the slave serverpublic String[] getSlaveServerNames()
public void renameJobEntryIfNameCollides(JobEntryCopy je)
je - The job entry copy to verify the name for.public SharedObjects getSharedObjects()
public void setSharedObjects(SharedObjects sharedObjects)
sharedObjects - the sharedObjects to setpublic void addNameChangedListener(NameChangedListener listener)
listener - the listenerpublic void removeNameChangedListener(NameChangedListener listener)
listener - the listenerpublic void addFilenameChangedListener(FilenameChangedListener listener)
listener - the listenerpublic void removeFilenameChangedListener(FilenameChangedListener listener)
listener - the listenerpublic void addContentChangedListener(ContentChangedListener listener)
listener - public void removeContentChangedListener(ContentChangedListener listener)
listener - public void activateParameters()
activateParameters in interface org.pentaho.di.core.parameters.NamedParamspublic void addParameterDefinition(String key, String defValue, String description) throws org.pentaho.di.core.parameters.DuplicateParamException
addParameterDefinition in interface org.pentaho.di.core.parameters.NamedParamsorg.pentaho.di.core.parameters.DuplicateParamExceptionpublic String getParameterDescription(String key) throws org.pentaho.di.core.parameters.UnknownParamException
getParameterDescription in interface org.pentaho.di.core.parameters.NamedParamsorg.pentaho.di.core.parameters.UnknownParamExceptionpublic String getParameterDefault(String key) throws org.pentaho.di.core.parameters.UnknownParamException
getParameterDefault in interface org.pentaho.di.core.parameters.NamedParamsorg.pentaho.di.core.parameters.UnknownParamExceptionpublic String getParameterValue(String key) throws org.pentaho.di.core.parameters.UnknownParamException
getParameterValue in interface org.pentaho.di.core.parameters.NamedParamsorg.pentaho.di.core.parameters.UnknownParamExceptionpublic String[] listParameters()
listParameters in interface org.pentaho.di.core.parameters.NamedParamspublic void setParameterValue(String key, String value) throws org.pentaho.di.core.parameters.UnknownParamException
setParameterValue in interface org.pentaho.di.core.parameters.NamedParamsorg.pentaho.di.core.parameters.UnknownParamExceptionpublic void eraseParameters()
eraseParameters in interface org.pentaho.di.core.parameters.NamedParamspublic void clearParameters()
clearParameters in interface org.pentaho.di.core.parameters.NamedParamspublic void copyParametersFrom(org.pentaho.di.core.parameters.NamedParams params)
copyParametersFrom in interface org.pentaho.di.core.parameters.NamedParamspublic List<JobEntryCopy> getJobCopies()
public List<NotePadMeta> getNotes()
public List<JobHopMeta> getJobhops()
public org.pentaho.di.repository.RepositoryObjectType getRepositoryElementType()
getRepositoryElementType in interface org.pentaho.di.repository.RepositoryElementInterfacepublic org.pentaho.di.repository.ObjectRevision getObjectRevision()
getObjectRevision in interface org.pentaho.di.core.logging.LoggingObjectInterfacegetObjectRevision in interface org.pentaho.di.repository.RepositoryElementInterfacepublic void setObjectRevision(org.pentaho.di.repository.ObjectRevision objectRevision)
setObjectRevision in interface org.pentaho.di.repository.RepositoryElementInterfacepublic List<JobEntryInterface> composeJobEntryInterfaceList()
public String getLogChannelId()
getLogChannelId in interface org.pentaho.di.core.logging.LoggingObjectInterfacepublic String getObjectName()
getObjectName in interface org.pentaho.di.core.logging.LoggingObjectInterfacepublic String getObjectCopy()
getObjectCopy in interface org.pentaho.di.core.logging.LoggingObjectInterfacepublic org.pentaho.di.core.logging.LoggingObjectType getObjectType()
getObjectType in interface org.pentaho.di.core.logging.LoggingObjectInterfacepublic org.pentaho.di.core.logging.LoggingObjectInterface getParent()
getParent in interface org.pentaho.di.core.logging.LoggingObjectInterfacepublic org.pentaho.di.core.logging.LogLevel getLogLevel()
getLogLevel in interface org.pentaho.di.core.logging.LoggingObjectInterfacepublic void setLogLevel(org.pentaho.di.core.logging.LogLevel logLevel)
logLevel - the new log levelpublic ChannelLogTable getChannelLogTable()
public void setChannelLogTable(ChannelLogTable channelLogTable)
channelLogTable - the channelLogTable to setpublic JobEntryLogTable getJobEntryLogTable()
public void setJobEntryLogTable(JobEntryLogTable jobEntryLogTable)
jobEntryLogTable - the jobEntryLogTable to setpublic List<LogTableInterface> getLogTables()
public boolean canSave()
canSave in interface EngineMetaInterfaceEngineMetaInterface.canSave()public String getContainerObjectId()
getContainerObjectId in interface org.pentaho.di.core.logging.LoggingObjectInterfacepublic void setCarteObjectId(String containerObjectId)
containerObjectId - the execution container Object id to setpublic Date getRegistrationDate()
getRegistrationDate in interface org.pentaho.di.core.logging.LoggingObjectInterfacepublic boolean hasRepositoryReferences()
public void lookupRepositoryReferences(Repository repository) throws org.pentaho.di.core.exception.KettleException
repository - the repository to reference.org.pentaho.di.core.exception.KettleExceptionpublic Repository getRepository()
getRepository in interface HasRepositoryInterfacepublic void setRepository(Repository repository)
setRepository in interface HasRepositoryInterfacerepository - the repository to setpublic boolean isGatheringMetrics()
isGatheringMetrics in interface org.pentaho.di.core.logging.LoggingObjectInterfacepublic void setGatheringMetrics(boolean gatheringMetrics)
setGatheringMetrics in interface org.pentaho.di.core.logging.LoggingObjectInterfacepublic boolean isForcingSeparateLogging()
isForcingSeparateLogging in interface org.pentaho.di.core.logging.LoggingObjectInterfacepublic void setForcingSeparateLogging(boolean forcingSeparateLogging)
setForcingSeparateLogging in interface org.pentaho.di.core.logging.LoggingObjectInterfacepublic org.pentaho.metastore.api.IMetaStore getMetaStore()
public void setMetaStore(org.pentaho.metastore.api.IMetaStore metaStore)
public void saveMetaStoreObjects(Repository repository, org.pentaho.metastore.api.IMetaStore metaStore) throws org.pentaho.metastore.api.exceptions.MetaStoreException
metaStore - The store to save toorg.pentaho.metastore.api.exceptions.MetaStoreException - in case there is an error.public void setAttributesMap(Map<String,Map<String,String>> attributesMap)
setAttributesMap in interface org.pentaho.di.core.AttributesInterfacepublic Map<String,Map<String,String>> getAttributesMap()
getAttributesMap in interface org.pentaho.di.core.AttributesInterfacepublic void setAttribute(String groupName, String key, String value)
setAttribute in interface org.pentaho.di.core.AttributesInterfacepublic void setAttributes(String groupName, Map<String,String> attributes)
setAttributes in interface org.pentaho.di.core.AttributesInterfacepublic Map<String,String> getAttributes(String groupName)
getAttributes in interface org.pentaho.di.core.AttributesInterfacepublic String getAttribute(String groupName, String key)
getAttribute in interface org.pentaho.di.core.AttributesInterfacepublic List<LogTableInterface> getExtraLogTables()
public void setExtraLogTables(List<LogTableInterface> extraLogTables)