public class JobMeta extends AbstractMeta implements Cloneable, Comparable<JobMeta>, org.pentaho.di.core.xml.XMLInterface, ResourceExportInterface, org.pentaho.di.repository.RepositoryElementInterface, org.pentaho.di.core.logging.LoggingObjectInterface
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 String |
XML_TAG |
TYPE_UNDO_CHANGE, TYPE_UNDO_DELETE, TYPE_UNDO_NEW, TYPE_UNDO_POSITION
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 |
addDefaults()
Adds the defaults.
|
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 |
addMissingEntry(MissingEntry missingEntry) |
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.
|
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
|
boolean |
containsJobCopy(JobEntryCopy jobCopy) |
int |
countEntries(String name)
Count entries.
|
static JobEntryCopy |
createDummyEntry()
Creates the dummy entry.
|
static JobEntryCopy |
createStartEntry()
Creates the start entry.
|
boolean |
equals(Object obj)
Checks whether this job's meta-data object is equal to the specified object.
|
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.
|
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.
|
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 |
getDefaultExtension()
Gets the default extension for a job.
|
JobEntryCopy |
getDummy()
Gets the dummy.
|
int[] |
getEntryIndexes(List<JobEntryCopy> entries)
Gets the entry indexes.
|
List<LogTableInterface> |
getExtraLogTables() |
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() |
List<LogTableInterface> |
getLogTables()
Gets the log tables.
|
org.pentaho.di.core.gui.Point |
getMaximum()
Gets the maximum.
|
org.pentaho.di.core.gui.Point |
getMinimum()
Get the minimum point on the canvas of a job
|
List<MissingEntry> |
getMissingEntries() |
org.pentaho.di.core.logging.LoggingObjectType |
getObjectType() |
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<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.
|
List<String> |
getUsedVariables()
Gets the used variables.
|
String |
getXML()
Gets the XML representation.
|
boolean |
hasChanged() |
boolean |
hasLoop(JobEntryCopy entry)
Checks for loop.
|
boolean |
hasLoop(JobEntryCopy entry,
JobEntryCopy lookup,
boolean info)
Checks for loop.
|
boolean |
hasMissingPlugins() |
boolean |
hasRepositoryReferences()
Checks whether the job has repository references.
|
boolean |
haveJobEntriesChanged()
Have job entries changed.
|
boolean |
haveJobHopsChanged()
Have job hops changed.
|
int |
indexOfJobEntry(JobEntryCopy ge)
Index of job entry.
|
int |
indexOfJobHop(JobHopMeta he)
Index of job hop.
|
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 |
isPathExist(JobEntryInterface from,
JobEntryInterface to) |
boolean |
isRepReference()
Checks if is rep reference.
|
static boolean |
isRepReference(String fileName,
String transName)
Checks if is rep reference.
|
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
|
int |
nrJobEntries()
Nr job entries.
|
int |
nrJobHops()
Nr job hops.
|
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 |
removeJobEntry(int i)
Removes the job entry.
|
void |
removeJobHop(int i)
Removes the job hop.
|
void |
removeJobHop(JobHopMeta hop)
Removes a hop from the transformation.
|
void |
removeMissingEntry(MissingEntry missingEntry) |
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 |
setBatchIdPassed(boolean batchIdPassed)
Sets the batch id passed.
|
void |
setExtraLogTables(List<LogTableInterface> extraLogTables) |
void |
setForcingSeparateLogging(boolean forcingSeparateLogging) |
void |
setGatheringMetrics(boolean gatheringMetrics)
Sets whether or not the job is gathering metrics.
|
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.
|
String |
toString()
Gets a textual representation of the job.
|
void |
unselectAll()
Unselect all.
|
activateParameters, addContentChangedListener, addDatabase, addDatabase, addFilenameChangedListener, addNameChangedListener, addNote, addNote, addObserver, addOrReplaceDatabase, addOrReplaceSlaveServer, addParameterDefinition, addUndo, canSave, clearChangedDatabases, clearParameters, clearUndo, copyParametersFrom, copyVariablesFrom, deleteObserver, environmentSubstitute, environmentSubstitute, eraseParameters, fieldSubstitute, findDatabase, findSlaveServer, getAttribute, getAttributes, getAttributesMap, getBooleanValueOfVariable, getChannelLogTable, getContainerObjectId, getContentChangedListeners, getCreatedDate, getCreatedUser, getDatabase, getDatabaseNames, getDatabases, getDescription, getEmbeddedMetaStore, getExtendedDescription, getFilename, getLogLevel, getMaxUndo, getMetaStore, getModifiedDate, getModifiedUser, getName, getNote, getNote, getNoteIndexes, getNotes, getObjectCopy, getObjectId, getObjectName, getObjectRevision, getParameterDefault, getParameterDescription, getParameterValue, getParent, getParentVariableSpace, getPrivateDatabases, getRegistrationDate, getRepository, getRepositoryDirectory, getSelectedNotes, getSharedObjects, getSharedObjectsFile, getSlaveServerNames, getSlaveServers, getUndoSize, getVariable, getVariable, haveConnectionsChanged, haveNotesChanged, importFromMetaStore, indexOfDatabase, indexOfNote, initializeVariablesFrom, injectVariables, isAlwaysShowRunOptions, isShowDialog, listParameters, listVariables, lowerNote, nameFromFilename, nextUndo, notifyObservers, nrDatabases, nrNotes, previousUndo, raiseNote, removeContentChangedListener, removeDatabase, removeFilenameChangedListener, removeNameChangedListener, removeNote, setAlwaysShowRunOptions, setAttribute, setAttributes, setAttributesMap, setCarteObjectId, setChanged, setChanged, setChannelLogTable, setCreatedDate, setCreatedUser, setDatabases, setDescription, setExtendedDescription, setFilename, setInternalKettleVariables, setLogLevel, setMaxUndo, setMetaStore, setModifiedDate, setModifiedUser, setName, setObjectId, setObjectRevision, setParameterValue, setParentVariableSpace, setPrivateDatabases, setRepository, setRepositoryDirectory, setSharedObjects, setSharedObjectsFile, setShowDialog, setSlaveServers, setVariable, shareVariablesWith, viewNextUndo, viewPreviousUndo, viewThisUndo
getClass, hashCode, notify, notifyAll, wait, wait, wait
public static final String XML_TAG
public static final org.pentaho.di.repository.RepositoryObjectType REPOSITORY_ELEMENT_TYPE
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
fname
- 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
fname
- 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 void clear()
clear
in class AbstractMeta
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 JobLogTable getJobLogTable()
public void setJobLogTable(JobLogTable jobLogTable)
jobLogTable
- the new job log tablepublic void clearChanged()
clearChanged
in interface ChangedFlagInterface
clearChanged
in interface EngineMetaInterface
clearChanged
in class AbstractMeta
public boolean hasChanged()
hasChanged
in interface ChangedFlagInterface
hasChanged
in class AbstractMeta
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 JobEntryCopy getJobEntryCopy(int x, int y, int iconsize)
x
- the xy
- the yiconsize
- the iconsizepublic int nrJobEntries()
public int nrJobHops()
public JobHopMeta getJobHop(int i)
i
- the ipublic JobEntryCopy getJobEntry(int i)
i
- the ipublic void addJobEntry(JobEntryCopy je)
je
- the jepublic void addJobHop(JobHopMeta hi)
hi
- the hipublic void addJobEntry(int p, JobEntryCopy si)
p
- the psi
- the sipublic void addJobHop(int p, JobHopMeta hi)
p
- the phi
- the hipublic void removeJobEntry(int i)
i
- the ipublic void removeJobHop(int i)
i
- the ipublic void removeJobHop(JobHopMeta hop)
hop
- The hop to remove from the list of hopspublic int indexOfJobHop(JobHopMeta he)
he
- the hepublic int indexOfJobEntry(JobEntryCopy ge)
ge
- the gepublic 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, boolean info)
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 boolean isPathExist(JobEntryInterface from, JobEntryInterface to)
public void selectAll()
public void unselectAll()
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 int[] getEntryIndexes(List<JobEntryCopy> entries)
entries
- the entriespublic 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 haveJobEntriesChanged()
public boolean haveJobHopsChanged()
public String getJobversion()
public int getJobstatus()
public void setJobversion(String jobVersion)
jobVersion
- The new version description of the jobpublic void setJobstatus(int jobStatus)
jobStatus
- The new status description of the jobpublic 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(org.pentaho.di.core.variables.VariableSpace var)
setInternalKettleVariables
in class AbstractMeta
@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 void renameJobEntryIfNameCollides(JobEntryCopy je)
je
- The job entry copy to verify the name for.public List<JobEntryCopy> getJobCopies()
public List<JobHopMeta> getJobhops()
public org.pentaho.di.repository.RepositoryObjectType getRepositoryElementType()
getRepositoryElementType
in interface org.pentaho.di.repository.RepositoryElementInterface
public List<JobEntryInterface> composeJobEntryInterfaceList()
public String getLogChannelId()
getLogChannelId
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 JobEntryLogTable getJobEntryLogTable()
public void setJobEntryLogTable(JobEntryLogTable jobEntryLogTable)
jobEntryLogTable
- the jobEntryLogTable to setpublic List<LogTableInterface> getLogTables()
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 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 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 List<LogTableInterface> getExtraLogTables()
public void setExtraLogTables(List<LogTableInterface> extraLogTables)
public boolean containsJobCopy(JobEntryCopy jobCopy)
public List<MissingEntry> getMissingEntries()
public void addMissingEntry(MissingEntry missingEntry)
public void removeMissingEntry(MissingEntry missingEntry)
public boolean hasMissingPlugins()
hasMissingPlugins
in class AbstractMeta