Package org.pentaho.di.base

Class AbstractMeta

java.lang.Object
org.pentaho.di.base.AbstractMeta
All Implemented Interfaces:
org.pentaho.di.core.AttributesInterface, org.pentaho.di.core.bowl.HasBowlInterface, ChangedFlagInterface, EngineMetaInterface, UndoInterface, org.pentaho.di.core.logging.LoggingObjectInterface, org.pentaho.di.core.logging.LoggingObjectLifecycleInterface, org.pentaho.di.core.parameters.NamedParams, org.pentaho.di.core.variables.VariableSpace, HasRepositoryInterface, org.pentaho.di.repository.RepositoryElementInterface, org.pentaho.di.repository.RepositoryObjectInterface, HasDatabasesInterface, HasSlaveServersInterface
Direct Known Subclasses:
JobMeta, TransMeta
public abstract class AbstractMeta extends Object implements ChangedFlagInterface, UndoInterface, HasDatabasesInterface, org.pentaho.di.core.variables.VariableSpace, EngineMetaInterface, org.pentaho.di.core.parameters.NamedParams, HasSlaveServersInterface, org.pentaho.di.core.AttributesInterface, HasRepositoryInterface, org.pentaho.di.core.bowl.HasBowlInterface, org.pentaho.di.core.logging.LoggingObjectInterface

  • Field Details

    • TYPE_UNDO_CHANGE

      public static final int TYPE_UNDO_CHANGE
      Constant = 1
      See Also:

    • TYPE_UNDO_NEW

      public static final int TYPE_UNDO_NEW
      Constant = 2
      See Also:

    • TYPE_UNDO_DELETE

      public static final int TYPE_UNDO_DELETE
      Constant = 3
      See Also:

    • TYPE_UNDO_POSITION

      public static final int TYPE_UNDO_POSITION
      Constant = 4
      See Also:

    • objectId

      protected org.pentaho.di.repository.ObjectId objectId

    • objectRevision

      protected org.pentaho.di.repository.ObjectRevision objectRevision

    • containerObjectId

      protected String containerObjectId

    • name

      protected String name

    • description

      protected String description

    • extendedDescription

      protected String extendedDescription

    • filename

      protected String filename

    • directory

      protected org.pentaho.di.repository.RepositoryDirectoryInterface directory

    • bowl

      protected org.pentaho.di.core.bowl.Bowl bowl

    • repository

      protected Repository repository
      The repository to reference in the one-off case that it is needed

    • databases

      protected List<org.pentaho.di.core.database.DatabaseMeta> databases

    • nameChangedListeners

      protected Set<NameChangedListener> nameChangedListeners

    • filenameChangedListeners

      protected Set<FilenameChangedListener> filenameChangedListeners

    • contentChangedListeners

      protected Set<ContentChangedListener> contentChangedListeners

    • currentDirectoryChangedListeners

      protected Set<CurrentDirectoryChangedListener> currentDirectoryChangedListeners

    • slaveServers

      protected List<SlaveServer> slaveServers

    • notes

      protected List<NotePadMeta> notes

    • channelLogTable

      protected ChannelLogTable channelLogTable

    • changedNotes

      protected boolean changedNotes

    • changedDatabases

      protected boolean changedDatabases

    • undo

      protected List<TransAction> undo

    • attributesMap

      protected Map<String,Map<String,String>> attributesMap

    • embeddedMetaStore

      protected EmbeddedMetaStore embeddedMetaStore

    • variables

      protected org.pentaho.di.core.variables.VariableSpace variables

    • namedParams

      protected org.pentaho.di.core.parameters.NamedParams namedParams

    • logLevel

      protected org.pentaho.di.core.logging.LogLevel logLevel

    • metaStore

      protected org.pentaho.metastore.api.IMetaStore metaStore

    • createdUser

      protected String createdUser

    • modifiedUser

      protected String modifiedUser

    • createdDate

      protected Date createdDate

    • modifiedDate

      protected Date modifiedDate

    • namedClusterServiceOsgi

      protected org.pentaho.di.core.osgi.api.NamedClusterServiceOsgi namedClusterServiceOsgi

    • metastoreLocatorOsgi

      protected org.pentaho.di.core.osgi.api.MetastoreLocatorOsgi metastoreLocatorOsgi

    • namedClusterEmbedManager

      protected NamedClusterEmbedManager namedClusterEmbedManager

    • sharedObjectsFile

      protected String sharedObjectsFile
      If this is null, we load from the default shared objects file : $KETTLE_HOME/.kettle/shared.xml

    • sharedObjects

      protected SharedObjects sharedObjects
      The last loaded version of the shared objects

    • changedFlag

      protected final ChangedFlag changedFlag

    • max_undo

      protected int max_undo

    • undo_position

      protected int undo_position

    • runOptions

      protected org.pentaho.di.base.AbstractMeta.RunOptions runOptions

    • privateDatabases

      protected Set<String> privateDatabases
      The set of names of databases available only for this meta. The list is needed to distinguish connections when we load/save the meta in JCR repository.

      Should be null if we use old meta

      See Also:

  • Constructor Details

    • AbstractMeta

      public AbstractMeta()

  • Method Details

    • isShowDialog

      public boolean isShowDialog()

    • setShowDialog

      public void setShowDialog(boolean showDialog)

    • isAlwaysShowRunOptions

      public boolean isAlwaysShowRunOptions()

    • setAlwaysShowRunOptions

      public void setAlwaysShowRunOptions(boolean alwaysShowRunOptions)

    • getObjectId

      public org.pentaho.di.repository.ObjectId getObjectId()
      Specified by:
      getObjectId in interface org.pentaho.di.core.logging.LoggingObjectInterface
      Specified by:
      getObjectId in interface org.pentaho.di.repository.RepositoryElementInterface
      Specified by:
      getObjectId in interface org.pentaho.di.repository.RepositoryObjectInterface

    • setObjectId

      public void setObjectId(org.pentaho.di.repository.ObjectId objectId)
      Description copied from interface: EngineMetaInterface
      Set the database ID for this in the repository.
      Specified by:
      setObjectId in interface EngineMetaInterface
      Specified by:
      setObjectId in interface org.pentaho.di.repository.RepositoryElementInterface
      Parameters:
      objectId - the database ID for this in the repository

    • getContainerObjectId

      public String getContainerObjectId()
      Gets the container object id.
      Specified by:
      getContainerObjectId in interface org.pentaho.di.core.logging.LoggingObjectInterface
      Returns:
      the carteObjectId

    • setCarteObjectId

      public void setCarteObjectId(String containerObjectId)
      Sets the carte object id.
      Parameters:
      containerObjectId - the execution container Object id to set

    • getName

      public String getName()
      Get the name of the transformation.
      Specified by:
      getName in interface EngineMetaInterface
      Specified by:
      getName in interface org.pentaho.di.repository.RepositoryElementInterface
      Specified by:
      getName in interface org.pentaho.di.repository.RepositoryObjectInterface
      Returns:
      The name of the transformation

    • setName

      public void setName(String newName)
      Set the name.
      Specified by:
      setName in interface org.pentaho.di.repository.RepositoryElementInterface
      Parameters:
      newName - The new name

    • getDescription

      public String getDescription()
      Gets the description of the job.
      Specified by:
      getDescription in interface org.pentaho.di.repository.RepositoryElementInterface
      Returns:
      The description of the job

    • setDescription

      public void setDescription(String description)
      Set the description of the job.
      Specified by:
      setDescription in interface org.pentaho.di.repository.RepositoryElementInterface
      Parameters:
      description - The new description of the job

    • getExtendedDescription

      public String getExtendedDescription()
      Gets the extended description of the job.
      Returns:
      The extended description of the job

    • setExtendedDescription

      public void setExtendedDescription(String extendedDescription)
      Set the description of the job.
      Parameters:
      extendedDescription - The new extended description of the job

    • nameFromFilename

      public void nameFromFilename()
      Builds a name - if no name is set, yet - from the filename
      Specified by:
      nameFromFilename in interface EngineMetaInterface

    • getFilename

      public String getFilename()
      Gets the filename.
      Specified by:
      getFilename in interface EngineMetaInterface
      Specified by:
      getFilename in interface org.pentaho.di.core.logging.LoggingObjectInterface
      Returns:
      filename
      See Also:

    • setFilename

      public void setFilename(String newFilename)
      Set the filename of the job
      Specified by:
      setFilename in interface EngineMetaInterface
      Parameters:
      newFilename - The new filename of the job

    • getRepositoryDirectory

      public org.pentaho.di.repository.RepositoryDirectoryInterface getRepositoryDirectory()
      Gets the directory.
      Specified by:
      getRepositoryDirectory in interface EngineMetaInterface
      Specified by:
      getRepositoryDirectory in interface org.pentaho.di.core.logging.LoggingObjectInterface
      Specified by:
      getRepositoryDirectory in interface org.pentaho.di.repository.RepositoryElementInterface
      Returns:
      Returns the directory.

    • setRepositoryDirectory

      public void setRepositoryDirectory(org.pentaho.di.repository.RepositoryDirectoryInterface directory)
      Sets the directory.
      Specified by:
      setRepositoryDirectory in interface org.pentaho.di.repository.RepositoryElementInterface
      Parameters:
      directory - The directory to set.

    • getBowl

      public org.pentaho.di.core.bowl.Bowl getBowl()
      Specified by:
      getBowl in interface org.pentaho.di.core.bowl.HasBowlInterface

    • setBowl

      public void setBowl(org.pentaho.di.core.bowl.Bowl bowl)
      Specified by:
      setBowl in interface org.pentaho.di.core.bowl.HasBowlInterface

    • getRepository

      public Repository getRepository()
      Gets the repository.
      Specified by:
      getRepository in interface HasRepositoryInterface
      Returns:
      the repository

    • setRepository

      public void setRepository(Repository repository)
      Sets the repository.
      Specified by:
      setRepository in interface HasRepositoryInterface
      Parameters:
      repository - the repository to set

    • setInternalKettleVariables

      public void setInternalKettleVariables()
      Calls setInternalKettleVariables on the default object.
      Specified by:
      setInternalKettleVariables in interface EngineMetaInterface

    • setInternalKettleVariables

      public abstract void setInternalKettleVariables(org.pentaho.di.core.variables.VariableSpace var)
      This method sets various internal kettle variables.

    • setInternalFilenameKettleVariables

      protected abstract void setInternalFilenameKettleVariables(org.pentaho.di.core.variables.VariableSpace var)
      Sets the internal filename kettle variables.
      Parameters:
      var - the new internal filename kettle variables

    • findDatabase

      public org.pentaho.di.core.database.DatabaseMeta findDatabase(String name)
      Find a database connection by it's name
      Specified by:
      findDatabase in interface HasDatabasesInterface
      Parameters:
      name - The database name to look for
      Returns:
      The database connection or null if nothing was found.

    • nrDatabases

      public int nrDatabases()
      Description copied from interface: HasDatabasesInterface
      Count the nr of databases in the transformation.
      Specified by:
      nrDatabases in interface HasDatabasesInterface
      Returns:
      The nr of databases

    • getDatabase

      public org.pentaho.di.core.database.DatabaseMeta getDatabase(int i)
      Description copied from interface: HasDatabasesInterface
      Retrieves a database connection information a a certain location.
      Specified by:
      getDatabase in interface HasDatabasesInterface
      Parameters:
      i - The database number.
      Returns:
      The database connection information.

    • importFromMetaStore

      public void importFromMetaStore() throws org.pentaho.metastore.api.exceptions.MetaStoreException, org.pentaho.di.core.exception.KettlePluginException
      Throws:
      org.pentaho.metastore.api.exceptions.MetaStoreException
      org.pentaho.di.core.exception.KettlePluginException

    • addNameChangedListener

      public void addNameChangedListener(NameChangedListener listener)
      Adds the name changed listener.
      Parameters:
      listener - the listener

    • removeNameChangedListener

      public void removeNameChangedListener(NameChangedListener listener)
      Removes the name changed listener.
      Parameters:
      listener - the listener

    • clearNameChangedListeners

      public void clearNameChangedListeners()
      Removes all the name changed listeners

    • fireNameChangedListeners

      protected void fireNameChangedListeners(String oldName, String newName)
      Fire name changed listeners.
      Parameters:
      oldName - the old name
      newName - the new name

    • addFilenameChangedListener

      public void addFilenameChangedListener(FilenameChangedListener listener)
      Adds the filename changed listener.
      Parameters:
      listener - the listener

    • removeFilenameChangedListener

      public void removeFilenameChangedListener(FilenameChangedListener listener)
      Removes the filename changed listener.
      Parameters:
      listener - the listener

    • fireFilenameChangedListeners

      protected void fireFilenameChangedListeners(String oldFilename, String newFilename)
      Fire filename changed listeners.
      Parameters:
      oldFilename - the old filename
      newFilename - the new filename

    • addContentChangedListener

      public void addContentChangedListener(ContentChangedListener listener)
      Adds the passed ContentChangedListener to the list of listeners.
      Parameters:
      listener -

    • removeContentChangedListener

      public void removeContentChangedListener(ContentChangedListener listener)
      Removes the passed ContentChangedListener from the list of listeners.
      Parameters:
      listener -

    • getContentChangedListeners

      public List<ContentChangedListener> getContentChangedListeners()

    • fireContentChangedListeners

      protected void fireContentChangedListeners()
      Fire content changed listeners.

    • fireContentChangedListeners

      protected void fireContentChangedListeners(boolean ch)

    • addCurrentDirectoryChangedListener

      public void addCurrentDirectoryChangedListener(CurrentDirectoryChangedListener listener)
      Remove listener

    • removeCurrentDirectoryChangedListener

      public void removeCurrentDirectoryChangedListener(CurrentDirectoryChangedListener listener)
      Add a listener to be notified of design-time changes to current directory variable

    • clearCurrentDirectoryChangedListeners

      public void clearCurrentDirectoryChangedListeners()

    • fireCurrentDirectoryChanged

      protected void fireCurrentDirectoryChanged(String previous, String current)
      Notify listeners of a change in current directory.

    • addOrReplaceSlaveServer

      public void addOrReplaceSlaveServer(SlaveServer slaveServer)
      Add a new slave server to the transformation if that didn't exist yet. Otherwise, replace it.
      Parameters:
      slaveServer - The slave server to be added.

    • getSlaveServers

      public List<SlaveServer> getSlaveServers()
      Gets a list of slave servers.
      Specified by:
      getSlaveServers in interface HasSlaveServersInterface
      Returns:
      the slaveServer list

    • setSlaveServers

      public void setSlaveServers(List<SlaveServer> slaveServers)
      Sets the slave servers.
      Parameters:
      slaveServers - the slaveServers to set

    • findSlaveServer

      public SlaveServer findSlaveServer(String serverString)
      Find a slave server using the name
      Parameters:
      serverString - the name of the slave server
      Returns:
      the slave server or null if we couldn't spot an approriate entry.

    • getSlaveServerNames

      public String[] getSlaveServerNames()
      Gets an array of slave server names.
      Returns:
      An array list slave server names

    • addUndo

      public void addUndo(Object[] from, Object[] to, int[] pos, org.pentaho.di.core.gui.Point[] prev, org.pentaho.di.core.gui.Point[] curr, int type_of_change, boolean nextAlso)
      Description copied from interface: UndoInterface
      Add an undo operation to the undo list
      Specified by:
      addUndo in interface UndoInterface
      Parameters:
      from - array of objects representing the old state
      to - array of objectes representing the new state
      pos - An array of object locations
      prev - An array of points representing the old positions
      curr - An array of points representing the new positions
      type_of_change - The type of change that's being done to the transformation.
      nextAlso - indicates that the next undo operation needs to follow this one.

    • clearUndo

      public void clearUndo()
      Clear undo.

    • nextUndo

      public TransAction nextUndo()
      Description copied from interface: UndoInterface
      Get the next undo transaction on the list. Change the undo pointer.
      Specified by:
      nextUndo in interface UndoInterface
      Returns:
      The next undo transaction (for redo)

    • viewNextUndo

      public TransAction viewNextUndo()
      Description copied from interface: UndoInterface
      Get the next undo transaction on the list.
      Specified by:
      viewNextUndo in interface UndoInterface
      Returns:
      The next undo transaction (for redo)

    • previousUndo

      public TransAction previousUndo()
      Description copied from interface: UndoInterface
      Get the previous undo operation and change the undo pointer
      Specified by:
      previousUndo in interface UndoInterface
      Returns:
      The undo transaction to be performed.

    • viewThisUndo

      public TransAction viewThisUndo()
      View current undo, don't change undo position
      Specified by:
      viewThisUndo in interface UndoInterface
      Returns:
      The current undo transaction

    • viewPreviousUndo

      public TransAction viewPreviousUndo()
      Description copied from interface: UndoInterface
      View previous undo, don't change undo position
      Specified by:
      viewPreviousUndo in interface UndoInterface
      Returns:
      The previous undo transaction

    • getMaxUndo

      public int getMaxUndo()
      Description copied from interface: UndoInterface
      Get the maximum number of undo operations possible
      Specified by:
      getMaxUndo in interface UndoInterface
      Returns:
      The maximum number of undo operations that are allowed.

    • setMaxUndo

      public void setMaxUndo(int mu)
      Description copied from interface: UndoInterface
      Sets the maximum number of undo operations that are allowed.
      Specified by:
      setMaxUndo in interface UndoInterface
      Parameters:
      mu - The maximum number of undo operations that are allowed.

    • getUndoSize

      public int getUndoSize()
      Gets the undo size.
      Returns:
      the undo size

    • getEmbeddedMetaStore

      public EmbeddedMetaStore getEmbeddedMetaStore()

    • setAttributesMap

      public void setAttributesMap(Map<String,Map<String,String>> attributesMap)
      Specified by:
      setAttributesMap in interface org.pentaho.di.core.AttributesInterface

    • getAttributesMap

      public Map<String,Map<String,String>> getAttributesMap()
      Specified by:
      getAttributesMap in interface org.pentaho.di.core.AttributesInterface

    • setAttribute

      public void setAttribute(String groupName, String key, String value)
      Specified by:
      setAttribute in interface org.pentaho.di.core.AttributesInterface

    • setAttributes

      public void setAttributes(String groupName, Map<String,String> attributes)
      Specified by:
      setAttributes in interface org.pentaho.di.core.AttributesInterface

    • getAttributes

      public Map<String,String> getAttributes(String groupName)
      Specified by:
      getAttributes in interface org.pentaho.di.core.AttributesInterface

    • getAttribute

      public String getAttribute(String groupName, String key)
      Specified by:
      getAttribute in interface org.pentaho.di.core.AttributesInterface

    • addNote

      public void addNote(int p, NotePadMeta ni)
      Add a new note at a certain location (i.e. the specified index). Also marks that the notes have changed.
      Parameters:
      p - The index into the notes list
      ni - The note to be added.

    • addNote

      public void addNote(NotePadMeta ni)
      Add a new note. Also marks that the notes have changed.
      Parameters:
      ni - The note to be added.

    • getNote

      public NotePadMeta getNote(int x, int y)
      Find the note that is located on a certain point on the canvas.
      Parameters:
      x - the x-coordinate of the point queried
      y - the y-coordinate of the point queried
      Returns:
      The note information if a note is located at the point. Otherwise, if nothing was found: null.

    • getNote

      public NotePadMeta getNote(int i)
      Gets the note.
      Parameters:
      i - the i
      Returns:
      the note

    • getNotes

      public List<NotePadMeta> getNotes()
      Gets the notes.
      Returns:
      the notes

    • getSelectedNotes

      public List<NotePadMeta> getSelectedNotes()
      Gets a list of all selected notes.
      Returns:
      A list of all the selected notes.

    • indexOfNote

      public int indexOfNote(NotePadMeta ni)
      Finds the location (index) of the specified note.
      Parameters:
      ni - The note queried
      Returns:
      The location of the note, or -1 if nothing was found.

    • lowerNote

      public void lowerNote(int p)
      Lowers a note to the "bottom" of the list by removing the note at the specified index and re-inserting it at the front. Also marks that the notes have changed.
      Parameters:
      p - the index into the notes list.

    • nrNotes

      public int nrNotes()
      Gets the number of notes.
      Returns:
      The number of notes.

    • raiseNote

      public void raiseNote(int p)
      Raises a note to the "top" of the list by removing the note at the specified index and re-inserting it at the end. Also marks that the notes have changed.
      Parameters:
      p - the index into the notes list.

    • removeNote

      public void removeNote(int i)
      Removes a note at a certain location (i.e. the specified index). Also marks that the notes have changed.
      Parameters:
      i - The index into the notes list

    • haveNotesChanged

      public boolean haveNotesChanged()
      Checks whether or not any of the notes have been changed.
      Returns:
      true if the notes have been changed, false otherwise

    • getNoteIndexes

      public int[] getNoteIndexes(List<NotePadMeta> notes)
      Get an array of the locations of an array of notes
      Parameters:
      notes - An array of notes
      Returns:
      an array of the locations of an array of notes

    • getChannelLogTable

      public ChannelLogTable getChannelLogTable()
      Gets the channel log table for the job.
      Returns:
      the channel log table for the job.

    • addOrReplaceDatabase

      public void addOrReplaceDatabase(org.pentaho.di.core.database.DatabaseMeta databaseMeta)
      Description copied from interface: HasDatabasesInterface
      Add a database connection to the transformation if that connection didn't exists yet. Otherwise, replace the connection in the transformation
      Specified by:
      addOrReplaceDatabase in interface HasDatabasesInterface
      Parameters:
      databaseMeta - The database connection information.

    • addDatabase

      protected void addDatabase(org.pentaho.di.core.database.DatabaseMeta databaseMeta, boolean replace)

    • addDatabase

      public void addDatabase(org.pentaho.di.core.database.DatabaseMeta ci)
      Description copied from interface: HasDatabasesInterface
      Add a database connection to the transformation.
      Specified by:
      addDatabase in interface HasDatabasesInterface
      Parameters:
      ci - The database connection information.

    • addDatabase

      public void addDatabase(int p, org.pentaho.di.core.database.DatabaseMeta ci)
      Description copied from interface: HasDatabasesInterface
      Add a database connection to the transformation on a certain location.
      Specified by:
      addDatabase in interface HasDatabasesInterface
      Parameters:
      p - The location
      ci - The database connection information.

    • getDatabases

      public List<org.pentaho.di.core.database.DatabaseMeta> getDatabases()
      Returns a list of the databases.
      Specified by:
      getDatabases in interface HasDatabasesInterface
      Returns:
      Returns the databases.

    • getDatabaseNames

      public String[] getDatabaseNames()
      Gets the database names.
      Returns:
      the database names

    • indexOfDatabase

      public int indexOfDatabase(org.pentaho.di.core.database.DatabaseMeta di)
      Description copied from interface: HasDatabasesInterface
      Find the location of database
      Specified by:
      indexOfDatabase in interface HasDatabasesInterface
      Parameters:
      di - The database queried
      Returns:
      The location of the database, -1 if nothing was found.

    • setDatabases

      public void setDatabases(List<org.pentaho.di.core.database.DatabaseMeta> databases)
      Sets the databases.
      Specified by:
      setDatabases in interface HasDatabasesInterface
      Parameters:
      databases - The databases to set.

    • haveConnectionsChanged

      public boolean haveConnectionsChanged()
      Description copied from interface: HasDatabasesInterface
      Checks whether or not the connections have changed.
      Specified by:
      haveConnectionsChanged in interface HasDatabasesInterface
      Returns:
      True if the connections have been changed.

    • removeDatabase

      public void removeDatabase(int i)
      Description copied from interface: HasDatabasesInterface
      Removes a database from the transformation on a certain location.
      Specified by:
      removeDatabase in interface HasDatabasesInterface
      Parameters:
      i - The location

    • clearChangedDatabases

      public void clearChangedDatabases()
      Clears the flags for whether the transformation's databases have changed.

    • setChannelLogTable

      public void setChannelLogTable(ChannelLogTable channelLogTable)
      Sets the channel log table for the job.
      Parameters:
      channelLogTable - the channelLogTable to set

    • copyVariablesFrom

      public void copyVariablesFrom(org.pentaho.di.core.variables.VariableSpace space)
      Specified by:
      copyVariablesFrom in interface org.pentaho.di.core.variables.VariableSpace

    • environmentSubstitute

      public String environmentSubstitute(String aString)
      Specified by:
      environmentSubstitute in interface org.pentaho.di.core.variables.VariableSpace

    • environmentSubstitute

      public String[] environmentSubstitute(String[] aString)
      Specified by:
      environmentSubstitute in interface org.pentaho.di.core.variables.VariableSpace

    • fieldSubstitute

      public String fieldSubstitute(String aString, org.pentaho.di.core.row.RowMetaInterface rowMeta, Object[] rowData) throws org.pentaho.di.core.exception.KettleValueException
      Specified by:
      fieldSubstitute in interface org.pentaho.di.core.variables.VariableSpace
      Throws:
      org.pentaho.di.core.exception.KettleValueException

    • getParentVariableSpace

      public org.pentaho.di.core.variables.VariableSpace getParentVariableSpace()
      Specified by:
      getParentVariableSpace in interface org.pentaho.di.core.variables.VariableSpace

    • setParentVariableSpace

      public void setParentVariableSpace(org.pentaho.di.core.variables.VariableSpace parent)
      Specified by:
      setParentVariableSpace in interface org.pentaho.di.core.variables.VariableSpace

    • getVariable

      public String getVariable(String variableName, String defaultValue)
      Specified by:
      getVariable in interface org.pentaho.di.core.variables.VariableSpace

    • getVariable

      public String getVariable(String variableName)
      Specified by:
      getVariable in interface org.pentaho.di.core.variables.VariableSpace

    • getBooleanValueOfVariable

      public boolean getBooleanValueOfVariable(String variableName, boolean defaultValue)
      Specified by:
      getBooleanValueOfVariable in interface org.pentaho.di.core.variables.VariableSpace

    • initializeVariablesFrom

      public void initializeVariablesFrom(org.pentaho.di.core.variables.VariableSpace parent)
      Specified by:
      initializeVariablesFrom in interface org.pentaho.di.core.variables.VariableSpace

    • listVariables

      public String[] listVariables()
      Specified by:
      listVariables in interface org.pentaho.di.core.variables.VariableSpace

    • setVariable

      public void setVariable(String variableName, String variableValue)
      Specified by:
      setVariable in interface org.pentaho.di.core.variables.VariableSpace

    • shareVariablesWith

      public void shareVariablesWith(org.pentaho.di.core.variables.VariableSpace space)
      Specified by:
      shareVariablesWith in interface org.pentaho.di.core.variables.VariableSpace

    • injectVariables

      public void injectVariables(Map<String,String> prop)
      Specified by:
      injectVariables in interface org.pentaho.di.core.variables.VariableSpace

    • addParameterDefinition

      public void addParameterDefinition(String key, String defValue, String description) throws org.pentaho.di.core.parameters.DuplicateParamException
      Specified by:
      addParameterDefinition in interface org.pentaho.di.core.parameters.NamedParams
      Throws:
      org.pentaho.di.core.parameters.DuplicateParamException

    • getParameterDescription

      public String getParameterDescription(String key) throws org.pentaho.di.core.parameters.UnknownParamException
      Specified by:
      getParameterDescription in interface org.pentaho.di.core.parameters.NamedParams
      Throws:
      org.pentaho.di.core.parameters.UnknownParamException

    • getParameterDefault

      public String getParameterDefault(String key) throws org.pentaho.di.core.parameters.UnknownParamException
      Specified by:
      getParameterDefault in interface org.pentaho.di.core.parameters.NamedParams
      Throws:
      org.pentaho.di.core.parameters.UnknownParamException

    • getParameterValue

      public String getParameterValue(String key) throws org.pentaho.di.core.parameters.UnknownParamException
      Specified by:
      getParameterValue in interface org.pentaho.di.core.parameters.NamedParams
      Throws:
      org.pentaho.di.core.parameters.UnknownParamException

    • listParameters

      public String[] listParameters()
      Specified by:
      listParameters in interface org.pentaho.di.core.parameters.NamedParams

    • setParameterValue

      public void setParameterValue(String key, String value) throws org.pentaho.di.core.parameters.UnknownParamException
      Specified by:
      setParameterValue in interface org.pentaho.di.core.parameters.NamedParams
      Throws:
      org.pentaho.di.core.parameters.UnknownParamException

    • eraseParameters

      public void eraseParameters()
      Specified by:
      eraseParameters in interface org.pentaho.di.core.parameters.NamedParams

    • clearParameters

      public void clearParameters()
      Specified by:
      clearParameters in interface org.pentaho.di.core.parameters.NamedParams

    • copyParametersFrom

      public void copyParametersFrom(org.pentaho.di.core.parameters.NamedParams params)
      Specified by:
      copyParametersFrom in interface org.pentaho.di.core.parameters.NamedParams

    • mergeParametersWith

      public void mergeParametersWith(org.pentaho.di.core.parameters.NamedParams params, boolean replace)
      Specified by:
      mergeParametersWith in interface org.pentaho.di.core.parameters.NamedParams

    • activateParameters

      public void activateParameters()
      Specified by:
      activateParameters in interface org.pentaho.di.core.parameters.NamedParams

    • getLogLevel

      public org.pentaho.di.core.logging.LogLevel getLogLevel()
      Specified by:
      getLogLevel in interface org.pentaho.di.core.logging.LoggingObjectInterface

    • setLogLevel

      public void setLogLevel(org.pentaho.di.core.logging.LogLevel logLevel)
      Sets the log level.
      Parameters:
      logLevel - the new log level

    • getMetaStore

      public org.pentaho.metastore.api.IMetaStore getMetaStore()

    • setMetaStore

      public void setMetaStore(org.pentaho.metastore.api.IMetaStore metaStore)

    • getSharedObjectsFile

      public String getSharedObjectsFile()
      Gets the shared objects file.
      Returns:
      the sharedObjectsFile

    • setSharedObjectsFile

      public void setSharedObjectsFile(String sharedObjectsFile)
      Sets the shared objects file.
      Parameters:
      sharedObjectsFile - the sharedObjectsFile to set

    • getSharedObjects

      public SharedObjects getSharedObjects()
      Gets the shared objects.
      Returns:
      the sharedObjects

    • setSharedObjects

      public void setSharedObjects(SharedObjects sharedObjects)
      Sets the shared objects.
      Parameters:
      sharedObjects - the sharedObjects to set

    • readSharedObjects

      public SharedObjects readSharedObjects() throws org.pentaho.di.core.exception.KettleException
      Read shared objects.
      Returns:
      the shared objects
      Throws:
      org.pentaho.di.core.exception.KettleException - the kettle exception

    • loadSharedObject

      public boolean loadSharedObject(org.pentaho.di.shared.SharedObjectInterface object)

    • setInternalNameKettleVariable

      protected abstract void setInternalNameKettleVariable(org.pentaho.di.core.variables.VariableSpace var)
      Sets the internal name kettle variable.
      Parameters:
      var - the new internal name kettle variable

    • getCreatedDate

      public Date getCreatedDate()
      Gets the date the transformation was created.
      Specified by:
      getCreatedDate in interface EngineMetaInterface
      Returns:
      the date the transformation was created.

    • setCreatedDate

      public void setCreatedDate(Date createdDate)
      Sets the date the transformation was created.
      Specified by:
      setCreatedDate in interface EngineMetaInterface
      Parameters:
      createdDate - The creation date to set.

    • setCreatedUser

      public void setCreatedUser(String createdUser)
      Sets the user by whom the transformation was created.
      Specified by:
      setCreatedUser in interface EngineMetaInterface
      Parameters:
      createdUser - The user to set.

    • getCreatedUser

      public String getCreatedUser()
      Gets the user by whom the transformation was created.
      Specified by:
      getCreatedUser in interface EngineMetaInterface
      Returns:
      the user by whom the transformation was created.

    • setModifiedDate

      public void setModifiedDate(Date modifiedDate)
      Sets the date the transformation was modified.
      Specified by:
      setModifiedDate in interface EngineMetaInterface
      Parameters:
      modifiedDate - The modified date to set.

    • getModifiedDate

      public Date getModifiedDate()
      Gets the date the transformation was modified.
      Specified by:
      getModifiedDate in interface EngineMetaInterface
      Returns:
      the date the transformation was modified.

    • setModifiedUser

      public void setModifiedUser(String modifiedUser)
      Sets the user who last modified the transformation.
      Specified by:
      setModifiedUser in interface EngineMetaInterface
      Parameters:
      modifiedUser - The user name to set.

    • getModifiedUser

      public String getModifiedUser()
      Gets the user who last modified the transformation.
      Specified by:
      getModifiedUser in interface EngineMetaInterface
      Returns:
      the user who last modified the transformation.

    • clear

      public void clear()

    • clearChanged

      public void clearChanged()
      Description copied from interface: EngineMetaInterface
      Clears the changed flag of this.
      Specified by:
      clearChanged in interface ChangedFlagInterface
      Specified by:
      clearChanged in interface EngineMetaInterface

    • setChanged

      public void setChanged()
      Specified by:
      setChanged in interface ChangedFlagInterface

    • setChanged

      public final void setChanged(boolean ch)
      Specified by:
      setChanged in interface ChangedFlagInterface

    • addObserver

      public void addObserver(PDIObserver o)

    • deleteObserver

      public void deleteObserver(PDIObserver o)

    • notifyObservers

      public void notifyObservers(Object arg)

    • canSave

      public boolean canSave()
      Checks whether the job can be saved. For JobMeta, this method always returns true
      Specified by:
      canSave in interface EngineMetaInterface
      Returns:
      true
      See Also:

    • hasChanged

      public boolean hasChanged()
      Specified by:
      hasChanged in interface ChangedFlagInterface

    • getRegistrationDate

      public Date getRegistrationDate()
      Gets the registration date for the transformation. For AbstractMeta, this method always returns null.
      Specified by:
      getRegistrationDate in interface org.pentaho.di.core.logging.LoggingObjectInterface
      Returns:
      null

    • getParent

      public org.pentaho.di.core.logging.LoggingObjectInterface getParent()
      Gets the interface to the parent log object. For AbstractMeta, this method always returns null.
      Specified by:
      getParent in interface org.pentaho.di.core.logging.LoggingObjectInterface
      Returns:
      null
      See Also:
      • LoggingObjectInterface.getParent()

    • getObjectName

      public String getObjectName()
      Specified by:
      getObjectName in interface org.pentaho.di.core.logging.LoggingObjectInterface

    • getObjectCopy

      public String getObjectCopy()
      Specified by:
      getObjectCopy in interface org.pentaho.di.core.logging.LoggingObjectInterface

    • getObjectRevision

      public org.pentaho.di.repository.ObjectRevision getObjectRevision()
      Specified by:
      getObjectRevision in interface org.pentaho.di.core.logging.LoggingObjectInterface
      Specified by:
      getObjectRevision in interface org.pentaho.di.repository.RepositoryElementInterface

    • setObjectRevision

      public void setObjectRevision(org.pentaho.di.repository.ObjectRevision objectRevision)
      Specified by:
      setObjectRevision in interface org.pentaho.di.repository.RepositoryElementInterface

    • shouldOverwrite

      protected boolean shouldOverwrite(org.pentaho.di.core.gui.OverwritePrompter prompter, org.pentaho.di.core.Props props, String message, String rememberMessage)

    • hasMissingPlugins

      public boolean hasMissingPlugins()

    • getPrivateDatabases

      public Set<String> getPrivateDatabases()
      Returns the set of databases available only for this meta or null if it was not initialized. Note, that the internal collection is returned with no protection wrapper!
      Returns:
      nonSharableDatabases

    • setPrivateDatabases

      public void setPrivateDatabases(Set<String> privateDatabases)
      Sets private databases' names
      Parameters:
      privateDatabases - - The list of databases available only for this meta

    • saveSharedObjects

      public void saveSharedObjects() throws org.pentaho.di.core.exception.KettleException
      Description copied from interface: EngineMetaInterface
      Saves shared objects, including databases, steps, partition schemas, slave servers, and cluster schemas, to a file.
      Specified by:
      saveSharedObjects in interface EngineMetaInterface
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getAllSharedObjects

      protected List<org.pentaho.di.shared.SharedObjectInterface> getAllSharedObjects()

    • saveMetaStoreObjects

      @Deprecated public void saveMetaStoreObjects(Repository repository, org.pentaho.metastore.api.IMetaStore metaStore) throws org.pentaho.metastore.api.exceptions.MetaStoreException
      Deprecated.
      This method is empty since 2013.
      This method needs to be called to store those objects which are used and referenced in the transformation metadata but not saved in the XML serialization. For example, the Kettle data service definition is referenced by name but not stored when getXML() is called.
      Parameters:
      metaStore - The store to save to
      Throws:
      org.pentaho.metastore.api.exceptions.MetaStoreException - in case there is an error.

    • compare

      protected int compare(AbstractMeta meta1, AbstractMeta meta2)

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • getNamedClusterServiceOsgi

      public org.pentaho.di.core.osgi.api.NamedClusterServiceOsgi getNamedClusterServiceOsgi()

    • setNamedClusterServiceOsgi

      public void setNamedClusterServiceOsgi(org.pentaho.di.core.osgi.api.NamedClusterServiceOsgi namedClusterServiceOsgi)

    • getMetastoreLocatorOsgi

      public org.pentaho.di.core.osgi.api.MetastoreLocatorOsgi getMetastoreLocatorOsgi()

    • setMetastoreLocatorOsgi

      public void setMetastoreLocatorOsgi(org.pentaho.di.core.osgi.api.MetastoreLocatorOsgi metastoreLocatorOsgi)

    • getNamedClusterEmbedManager

      public NamedClusterEmbedManager getNamedClusterEmbedManager()

    • disposeEmbeddedMetastoreProvider

      public void disposeEmbeddedMetastoreProvider()

    • getEmbeddedMetastoreProviderKey

      public String getEmbeddedMetastoreProviderKey()

    • setVersioningEnabled

      public void setVersioningEnabled(Boolean versioningEnabled)
      Description copied from interface: EngineMetaInterface
      Set versioning enabled
      Specified by:
      setVersioningEnabled in interface EngineMetaInterface
      Parameters:
      versioningEnabled - is versioning enabled

    • getVersioningEnabled

      public Boolean getVersioningEnabled()
      Description copied from interface: EngineMetaInterface
      Is versioning enabled.
      Specified by:
      getVersioningEnabled in interface EngineMetaInterface
      Returns:
      is versioning enabled

    • isClearingLog

      public boolean isClearingLog()

    • setClearingLog

      public void setClearingLog(boolean clearingLog)

    • isSafeModeEnabled

      public boolean isSafeModeEnabled()

    • setSafeModeEnabled

      public void setSafeModeEnabled(boolean safeModeEnabled)

    • getMetaFileCache

      public IMetaFileCache getMetaFileCache()

    • setMetaFileCache

      public void setMetaFileCache(IMetaFileCache metaFileCache)