Package org.pentaho.di.base

Class AbstractMeta

    • Field Detail

      • TYPE_UNDO_CHANGE

        public static final int TYPE_UNDO_CHANGE
        Constant = 1
        See Also:
        Constant Field Values

      • TYPE_UNDO_DELETE

        public static final int TYPE_UNDO_DELETE
        Constant = 3
        See Also:
        Constant Field Values

      • TYPE_UNDO_POSITION

        public static final int TYPE_UNDO_POSITION
        Constant = 4
        See Also:
        Constant Field Values

      • objectId

        protected org.pentaho.di.repository.ObjectId objectId

      • objectRevision

        protected org.pentaho.di.repository.ObjectRevision objectRevision

      • containerObjectId

        protected String containerObjectId

      • description

        protected String description

      • extendedDescription

        protected String extendedDescription

      • filename

        protected String filename

      • directory

        protected org.pentaho.di.repository.RepositoryDirectoryInterface directory

      • 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

      • changedNotes

        protected boolean changedNotes

      • changedDatabases

        protected boolean changedDatabases

      • 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

      • 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

      • 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:
        PPP-3405, PPP-3413

    • Constructor Detail

      • AbstractMeta

        public AbstractMeta()

    • Method Detail

      • 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

      • 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.

      • 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.

      • 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 -

      • fireContentChangedListeners

        protected void fireContentChangedListeners()
        Fire content changed listeners.

      • fireContentChangedListeners

        protected void fireContentChangedListeners​(boolean ch)

      • 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.

      • 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

      • 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

      • 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.

      • 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

        protected 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()

      • addObserver

        public void addObserver​(PDIObserver o)

      • deleteObserver

        public void deleteObserver​(PDIObserver o)

      • notifyObservers

        public void notifyObservers​(Object arg)

      • 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.

      • 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)

      • disposeEmbeddedMetastoreProvider

        public void disposeEmbeddedMetastoreProvider()

      • getEmbeddedMetastoreProviderKey

        public String getEmbeddedMetastoreProviderKey()

      • isClearingLog

        public boolean isClearingLog()

      • setClearingLog

        public void setClearingLog​(boolean clearingLog)

      • isSafeModeEnabled

        public boolean isSafeModeEnabled()

      • setSafeModeEnabled

        public void setSafeModeEnabled​(boolean safeModeEnabled)

      • setMetaFileCache

        public void setMetaFileCache​(IMetaFileCache metaFileCache)