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, setChanged
public 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.KettleXMLException
public 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.KettleXMLException
public 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.KettleXMLException
public 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.KettleXMLException
public org.pentaho.di.repository.ObjectId getObjectId()
getObjectId
in interface org.pentaho.di.core.logging.LoggingObjectInterface
getObjectId
in interface org.pentaho.di.repository.RepositoryElementInterface
getObjectId
in interface org.pentaho.di.repository.RepositoryObjectInterface
public void setObjectId(org.pentaho.di.repository.ObjectId objectId)
EngineMetaInterface
setObjectId
in interface EngineMetaInterface
setObjectId
in interface org.pentaho.di.repository.RepositoryElementInterface
objectId
- 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 Object
obj
- the objcompare(JobMeta, JobMeta)
,
Object.equals(java.lang.Object)
public Object clone()
clone
in class Object
Object.clone()
public Object realClone(boolean doClear)
doClear
- Whether to clear all of the clone's data before copying from the source objectpublic String getName()
EngineMetaInterface
getName
in interface EngineMetaInterface
getName
in interface org.pentaho.di.repository.RepositoryElementInterface
getName
in interface org.pentaho.di.repository.RepositoryObjectInterface
public void setName(String newName)
setName
in interface org.pentaho.di.repository.RepositoryElementInterface
newName
- The new name of the jobpublic void nameFromFilename()
nameFromFilename
in interface EngineMetaInterface
public org.pentaho.di.repository.RepositoryDirectoryInterface getRepositoryDirectory()
getRepositoryDirectory
in interface EngineMetaInterface
getRepositoryDirectory
in interface org.pentaho.di.core.logging.LoggingObjectInterface
getRepositoryDirectory
in interface org.pentaho.di.repository.RepositoryElementInterface
public void setRepositoryDirectory(org.pentaho.di.repository.RepositoryDirectoryInterface directory)
setRepositoryDirectory
in interface org.pentaho.di.repository.RepositoryElementInterface
directory
- The directory to set.public String getFilename()
getFilename
in interface EngineMetaInterface
getFilename
in interface org.pentaho.di.core.logging.LoggingObjectInterface
EngineMetaInterface.getFilename()
public void setFilename(String newFilename)
setFilename
in interface EngineMetaInterface
newFilename
- 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 HasDatabasesInterface
public String[] getDatabaseNames()
public void setDatabases(List<org.pentaho.di.core.database.DatabaseMeta> databases)
setDatabases
in interface HasDatabasesInterface
databases
- The databases to set.public void setChanged(boolean ch)
ChangedFlag
setChanged
in interface ChangedFlagInterface
setChanged
in class ChangedFlag
public void clearChanged()
clearChanged
in interface ChangedFlagInterface
clearChanged
in interface EngineMetaInterface
clearChanged
in class ChangedFlag
public boolean hasChanged()
ChangedFlag
hasChanged
in interface ChangedFlagInterface
hasChanged
in class ChangedFlag
public boolean isDatabaseConnectionUsed(org.pentaho.di.core.database.DatabaseMeta databaseMeta)
databaseMeta
- The connection to checkpublic String getFileType()
EngineMetaInterface
getFileType
in interface EngineMetaInterface
public String[] getFilterNames()
getFilterNames
in interface EngineMetaInterface
EngineMetaInterface.getFilterNames()
public String[] getFilterExtensions()
Const.STRING_JOB_FILTER_EXT
getFilterExtensions
in interface EngineMetaInterface
EngineMetaInterface.getFilterExtensions()
public String getDefaultExtension()
Const.STRING_JOB_DEFAULT_EXT
getDefaultExtension
in interface EngineMetaInterface
EngineMetaInterface.getDefaultExtension()
public String getXML()
EngineMetaInterface
getXML
in interface EngineMetaInterface
getXML
in interface org.pentaho.di.core.xml.XMLInterface
XMLInterface.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.KettleXMLException
public 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.KettleXMLException
public 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
EngineMetaInterface
saveSharedObjects
in interface EngineMetaInterface
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.database.DatabaseMeta findDatabase(String name)
findDatabase
in interface HasDatabasesInterface
name
- 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()
HasDatabasesInterface
nrDatabases
in interface HasDatabasesInterface
public 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)
HasDatabasesInterface
getDatabase
in interface HasDatabasesInterface
i
- 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)
HasDatabasesInterface
addDatabase
in interface HasDatabasesInterface
ci
- 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)
HasDatabasesInterface
addDatabase
in interface HasDatabasesInterface
p
- The locationci
- The database connection information.public void addOrReplaceDatabase(org.pentaho.di.core.database.DatabaseMeta databaseMeta)
HasDatabasesInterface
addOrReplaceDatabase
in interface HasDatabasesInterface
databaseMeta
- 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)
HasDatabasesInterface
removeDatabase
in interface HasDatabasesInterface
i
- 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)
HasDatabasesInterface
indexOfDatabase
in interface HasDatabasesInterface
di
- 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()
UndoInterface
getMaxUndo
in interface UndoInterface
public void setMaxUndo(int mu)
UndoInterface
setMaxUndo
in interface UndoInterface
mu
- 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)
UndoInterface
addUndo
in interface UndoInterface
from
- 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()
UndoInterface
previousUndo
in interface UndoInterface
public TransAction viewThisUndo()
viewThisUndo
in interface UndoInterface
public TransAction viewPreviousUndo()
UndoInterface
viewPreviousUndo
in interface UndoInterface
public TransAction nextUndo()
UndoInterface
nextUndo
in interface UndoInterface
public TransAction viewNextUndo()
UndoInterface
viewNextUndo
in interface UndoInterface
public 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.KettleException
public 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()
HasDatabasesInterface
haveConnectionsChanged
in interface HasDatabasesInterface
public 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 EngineMetaInterface
modifiedUser
- The modifiedUser to set.public String getModifiedUser()
getModifiedUser
in interface EngineMetaInterface
public void setModifiedDate(Date modifiedDate)
setModifiedDate
in interface EngineMetaInterface
modifiedDate
- The modifiedDate to set.public Date getModifiedDate()
getModifiedDate
in interface EngineMetaInterface
public String getDescription()
getDescription
in interface org.pentaho.di.repository.RepositoryElementInterface
public String getExtendedDescription()
public String getJobversion()
public int getJobstatus()
public void setDescription(String description)
setDescription
in interface org.pentaho.di.repository.RepositoryElementInterface
description
- 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 EngineMetaInterface
public void setCreatedDate(Date createdDate)
EngineMetaInterface
setCreatedDate
in interface EngineMetaInterface
createdDate
- The createdDate to set.public void setCreatedUser(String createdUser)
EngineMetaInterface
setCreatedUser
in interface EngineMetaInterface
createdUser
- The createdUser to set.public String getCreatedUser()
getCreatedUser
in interface EngineMetaInterface
public 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 EngineMetaInterface
public 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.VariableSpace
public String environmentSubstitute(String aString)
environmentSubstitute
in interface org.pentaho.di.core.variables.VariableSpace
public String[] environmentSubstitute(String[] aString)
environmentSubstitute
in interface org.pentaho.di.core.variables.VariableSpace
public 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.VariableSpace
org.pentaho.di.core.exception.KettleValueException
public org.pentaho.di.core.variables.VariableSpace getParentVariableSpace()
getParentVariableSpace
in interface org.pentaho.di.core.variables.VariableSpace
public void setParentVariableSpace(org.pentaho.di.core.variables.VariableSpace parent)
setParentVariableSpace
in interface org.pentaho.di.core.variables.VariableSpace
public String getVariable(String variableName, String defaultValue)
getVariable
in interface org.pentaho.di.core.variables.VariableSpace
public String getVariable(String variableName)
getVariable
in interface org.pentaho.di.core.variables.VariableSpace
public boolean getBooleanValueOfVariable(String variableName, boolean defaultValue)
getBooleanValueOfVariable
in interface org.pentaho.di.core.variables.VariableSpace
public void initializeVariablesFrom(org.pentaho.di.core.variables.VariableSpace parent)
initializeVariablesFrom
in interface org.pentaho.di.core.variables.VariableSpace
public String[] listVariables()
listVariables
in interface org.pentaho.di.core.variables.VariableSpace
public void setVariable(String variableName, String variableValue)
setVariable
in interface org.pentaho.di.core.variables.VariableSpace
public void shareVariablesWith(org.pentaho.di.core.variables.VariableSpace space)
shareVariablesWith
in interface org.pentaho.di.core.variables.VariableSpace
public 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
ResourceExportInterface
exportResources
in interface ResourceExportInterface
space
- 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 HasSlaveServersInterface
public 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.NamedParams
public void addParameterDefinition(String key, String defValue, String description) throws org.pentaho.di.core.parameters.DuplicateParamException
addParameterDefinition
in interface org.pentaho.di.core.parameters.NamedParams
org.pentaho.di.core.parameters.DuplicateParamException
public String getParameterDescription(String key) throws org.pentaho.di.core.parameters.UnknownParamException
getParameterDescription
in interface org.pentaho.di.core.parameters.NamedParams
org.pentaho.di.core.parameters.UnknownParamException
public String getParameterDefault(String key) throws org.pentaho.di.core.parameters.UnknownParamException
getParameterDefault
in interface org.pentaho.di.core.parameters.NamedParams
org.pentaho.di.core.parameters.UnknownParamException
public String getParameterValue(String key) throws org.pentaho.di.core.parameters.UnknownParamException
getParameterValue
in interface org.pentaho.di.core.parameters.NamedParams
org.pentaho.di.core.parameters.UnknownParamException
public String[] listParameters()
listParameters
in interface org.pentaho.di.core.parameters.NamedParams
public void setParameterValue(String key, String value) throws org.pentaho.di.core.parameters.UnknownParamException
setParameterValue
in interface org.pentaho.di.core.parameters.NamedParams
org.pentaho.di.core.parameters.UnknownParamException
public void eraseParameters()
eraseParameters
in interface org.pentaho.di.core.parameters.NamedParams
public void clearParameters()
clearParameters
in interface org.pentaho.di.core.parameters.NamedParams
public void copyParametersFrom(org.pentaho.di.core.parameters.NamedParams params)
copyParametersFrom
in interface org.pentaho.di.core.parameters.NamedParams
public 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.RepositoryElementInterface
public org.pentaho.di.repository.ObjectRevision getObjectRevision()
getObjectRevision
in interface org.pentaho.di.core.logging.LoggingObjectInterface
getObjectRevision
in interface org.pentaho.di.repository.RepositoryElementInterface
public void setObjectRevision(org.pentaho.di.repository.ObjectRevision objectRevision)
setObjectRevision
in interface org.pentaho.di.repository.RepositoryElementInterface
public List<JobEntryInterface> composeJobEntryInterfaceList()
public String getLogChannelId()
getLogChannelId
in interface org.pentaho.di.core.logging.LoggingObjectInterface
public String getObjectName()
getObjectName
in interface org.pentaho.di.core.logging.LoggingObjectInterface
public String getObjectCopy()
getObjectCopy
in interface org.pentaho.di.core.logging.LoggingObjectInterface
public org.pentaho.di.core.logging.LoggingObjectType getObjectType()
getObjectType
in interface org.pentaho.di.core.logging.LoggingObjectInterface
public org.pentaho.di.core.logging.LoggingObjectInterface getParent()
getParent
in interface org.pentaho.di.core.logging.LoggingObjectInterface
public org.pentaho.di.core.logging.LogLevel getLogLevel()
getLogLevel
in interface org.pentaho.di.core.logging.LoggingObjectInterface
public 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 EngineMetaInterface
EngineMetaInterface.canSave()
public String getContainerObjectId()
getContainerObjectId
in interface org.pentaho.di.core.logging.LoggingObjectInterface
public void setCarteObjectId(String containerObjectId)
containerObjectId
- the execution container Object id to setpublic Date getRegistrationDate()
getRegistrationDate
in interface org.pentaho.di.core.logging.LoggingObjectInterface
public boolean hasRepositoryReferences()
public void lookupRepositoryReferences(Repository repository) throws org.pentaho.di.core.exception.KettleException
repository
- the repository to reference.org.pentaho.di.core.exception.KettleException
public Repository getRepository()
getRepository
in interface HasRepositoryInterface
public void setRepository(Repository repository)
setRepository
in interface HasRepositoryInterface
repository
- the repository to setpublic boolean isGatheringMetrics()
isGatheringMetrics
in interface org.pentaho.di.core.logging.LoggingObjectInterface
public void setGatheringMetrics(boolean gatheringMetrics)
setGatheringMetrics
in interface org.pentaho.di.core.logging.LoggingObjectInterface
public boolean isForcingSeparateLogging()
isForcingSeparateLogging
in interface org.pentaho.di.core.logging.LoggingObjectInterface
public void setForcingSeparateLogging(boolean forcingSeparateLogging)
setForcingSeparateLogging
in interface org.pentaho.di.core.logging.LoggingObjectInterface
public 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.AttributesInterface
public Map<String,Map<String,String>> getAttributesMap()
getAttributesMap
in interface org.pentaho.di.core.AttributesInterface
public void setAttribute(String groupName, String key, String value)
setAttribute
in interface org.pentaho.di.core.AttributesInterface
public void setAttributes(String groupName, Map<String,String> attributes)
setAttributes
in interface org.pentaho.di.core.AttributesInterface
public Map<String,String> getAttributes(String groupName)
getAttributes
in interface org.pentaho.di.core.AttributesInterface
public String getAttribute(String groupName, String key)
getAttribute
in interface org.pentaho.di.core.AttributesInterface
public List<LogTableInterface> getExtraLogTables()
public void setExtraLogTables(List<LogTableInterface> extraLogTables)