Package org.pentaho.di.repository

Interface Repository

All Known Subinterfaces:
ReconnectableRepository, RepositoryExtended
All Known Implementing Classes:
AbstractRepository, KettleDatabaseRepository, KettleDatabaseRepositoryBase, KettleFileRepository
public interface Repository

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    clearSharedObjectCache()
    Clear the shared object cache, if applicable.
    void
    connect(String username, String password)
    Connect to the repository.
    int
    countNrJobEntryAttributes(org.pentaho.di.repository.ObjectId id_jobentry, String code)
     
    int
    countNrStepAttributes(org.pentaho.di.repository.ObjectId id_step, String code)
     
    org.pentaho.di.repository.RepositoryDirectoryInterface
    createRepositoryDirectory(org.pentaho.di.repository.RepositoryDirectoryInterface parentDirectory, String directoryPath)
    Create a new directory, possibly by creating several sub-directies of / at the same time.
    void
    deleteClusterSchema(org.pentaho.di.repository.ObjectId id_cluster)
     
    void
    deleteDatabaseMeta(String databaseName)
    Remove a database connection from the repository
    void
    deleteJob(org.pentaho.di.repository.ObjectId id_job)
     
    void
    deletePartitionSchema(org.pentaho.di.repository.ObjectId id_partition_schema)
     
    void
    deleteRepositoryDirectory(org.pentaho.di.repository.RepositoryDirectoryInterface dir)
     
    void
    deleteSlave(org.pentaho.di.repository.ObjectId id_slave)
     
    void
    deleteTransformation(org.pentaho.di.repository.ObjectId id_transformation)
    Delete everything related to a transformation from the repository.
    void
    disconnect()
    Disconnect from the repository.
    boolean
    exists(String name, org.pentaho.di.repository.RepositoryDirectoryInterface repositoryDirectory, org.pentaho.di.repository.RepositoryObjectType objectType)
    See if a repository object exists in the repository
    org.pentaho.di.repository.RepositoryDirectoryInterface
    findDirectory(String directory)
     
    org.pentaho.di.repository.RepositoryDirectoryInterface
    findDirectory(org.pentaho.di.repository.ObjectId directory)
     
    org.pentaho.di.repository.ObjectId
    getClusterID(String name)
     
    org.pentaho.di.repository.ObjectId[]
    getClusterIDs(boolean includeDeleted)
     
    String[]
    getClusterNames(boolean includeDeleted)
     
    String
    getConnectMessage()
    This is an informational message that a repository can display on connecting within Spoon.
    org.pentaho.di.repository.ObjectId
    getDatabaseID(String name)
     
    org.pentaho.di.repository.ObjectId[]
    getDatabaseIDs(boolean includeDeleted)
     
    String[]
    getDatabaseNames(boolean includeDeleted)
     
    org.pentaho.di.repository.RepositoryDirectoryInterface
    getDefaultSaveDirectory(org.pentaho.di.repository.RepositoryElementInterface repositoryElement)
     
    String[]
    getDirectoryNames(org.pentaho.di.repository.ObjectId id_directory)
    Returns the child directory names of a parent directory
    IRepositoryExporter
    getExporter()
     
    IRepositoryImporter
    getImporter()
     
    List<org.pentaho.di.repository.RepositoryElementMetaInterface>
    getJobAndTransformationObjects(org.pentaho.di.repository.ObjectId id_directory, boolean includeDeleted)
    Gets all job and transformation objects in the given directory.
    boolean
    getJobEntryAttributeBoolean(org.pentaho.di.repository.ObjectId id_jobentry, int nr, String code)
     
    boolean
    getJobEntryAttributeBoolean(org.pentaho.di.repository.ObjectId id_jobentry, String code)
     
    boolean
    getJobEntryAttributeBoolean(org.pentaho.di.repository.ObjectId id_jobentry, String code, boolean def)
     
    long
    getJobEntryAttributeInteger(org.pentaho.di.repository.ObjectId id_jobentry, int nr, String code)
     
    long
    getJobEntryAttributeInteger(org.pentaho.di.repository.ObjectId id_jobentry, String code)
     
    String
    getJobEntryAttributeString(org.pentaho.di.repository.ObjectId id_jobentry, int nr, String code)
     
    String
    getJobEntryAttributeString(org.pentaho.di.repository.ObjectId id_jobentry, String code)
     
    org.pentaho.di.repository.ObjectId
    getJobId(String name, org.pentaho.di.repository.RepositoryDirectoryInterface repositoryDirectory)
     
    String[]
    getJobNames(org.pentaho.di.repository.ObjectId id_directory, boolean includeDeleted)
     
    List<org.pentaho.di.repository.RepositoryElementMetaInterface>
    getJobObjects(org.pentaho.di.repository.ObjectId id_directory, boolean includeDeleted)
     
    String[]
    getJobsUsingDatabase(org.pentaho.di.repository.ObjectId id_database)
    Get the repository version.
    org.pentaho.di.core.logging.LogChannelInterface
    getLog()
     
    String
    getName()
     
    RepositoryObject
    getObjectInformation(org.pentaho.di.repository.ObjectId objectId, org.pentaho.di.repository.RepositoryObjectType objectType)
    Get more information about a certain object ID in the form of the RepositoryObject
    org.pentaho.di.repository.ObjectId
    getPartitionSchemaID(String name)
     
    org.pentaho.di.repository.ObjectId[]
    getPartitionSchemaIDs(boolean includeDeleted)
     
    String[]
    getPartitionSchemaNames(boolean includeDeleted)
     
    RepositoryMeta
    getRepositoryMeta()
     
    org.pentaho.metastore.api.IMetaStore
    getRepositoryMetaStore()
     
    RepositorySecurityManager
    getSecurityManager()
     
    RepositorySecurityProvider
    getSecurityProvider()
     
    IRepositoryService
    getService(Class<? extends IRepositoryService> clazz)
    Retrieves a given repository service
    List<Class<? extends IRepositoryService>>
    getServiceInterfaces()
    Retrieves the current list of of IRepository Services.
    org.pentaho.di.repository.ObjectId
    getSlaveID(String name)
     
    org.pentaho.di.repository.ObjectId[]
    getSlaveIDs(boolean includeDeleted)
     
    String[]
    getSlaveNames(boolean includeDeleted)
     
    List<SlaveServer>
    getSlaveServers()
     
    boolean
    getStepAttributeBoolean(org.pentaho.di.repository.ObjectId id_step, int nr, String code)
     
    boolean
    getStepAttributeBoolean(org.pentaho.di.repository.ObjectId id_step, int nr, String code, boolean def)
     
    boolean
    getStepAttributeBoolean(org.pentaho.di.repository.ObjectId id_step, String code)
     
    long
    getStepAttributeInteger(org.pentaho.di.repository.ObjectId id_step, int nr, String code)
     
    long
    getStepAttributeInteger(org.pentaho.di.repository.ObjectId id_step, String code)
     
    String
    getStepAttributeString(org.pentaho.di.repository.ObjectId id_step, int nr, String code)
     
    String
    getStepAttributeString(org.pentaho.di.repository.ObjectId id_step, String code)
     
    org.pentaho.di.repository.ObjectId
    getTransformationID(String name, org.pentaho.di.repository.RepositoryDirectoryInterface repositoryDirectory)
     
    String[]
    getTransformationNames(org.pentaho.di.repository.ObjectId id_directory, boolean includeDeleted)
     
    List<org.pentaho.di.repository.RepositoryElementMetaInterface>
    getTransformationObjects(org.pentaho.di.repository.ObjectId id_directory, boolean includeDeleted)
     
    String[]
    getTransformationsUsingDatabase(org.pentaho.di.repository.ObjectId id_database)
     
    org.pentaho.platform.api.repository2.unified.IUnifiedRepository
    getUnderlyingRepository()
     
    default Optional<URI>
    getUri()
    Returns the URI of the repository location, if defined by the implementation
    org.pentaho.di.repository.RepositoryDirectoryInterface
    getUserHomeDirectory()
     
    IUser
    getUserInfo()
     
    String
    getVersion()
    Get the repository version.
    boolean
    hasService(Class<? extends IRepositoryService> clazz)
    Checks whether a given repository service is available or not
    void
    init(RepositoryMeta repositoryMeta)
    Initialize the repository with the repository metadata and user information.
    void
    insertJobEntryDatabase(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, org.pentaho.di.repository.ObjectId id_database)
     
    org.pentaho.di.repository.ObjectId
    insertLogEntry(String description)
    Insert an entry in the audit trail of the repository.
    void
    insertStepDatabase(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, org.pentaho.di.repository.ObjectId id_database)
     
    boolean
    isConnected()
     
    ClusterSchema
    loadClusterSchema(org.pentaho.di.repository.ObjectId id_cluster_schema, List<SlaveServer> slaveServers, String versionLabel)
     
    org.pentaho.di.core.Condition
    loadConditionFromStepAttribute(org.pentaho.di.repository.ObjectId id_step, String code)
    Load a condition from the repository with the Object ID stored in a step attribute.
    org.pentaho.di.core.database.DatabaseMeta
    loadDatabaseMeta(org.pentaho.di.repository.ObjectId id_database, String revision)
    Load the Database connection Metadata from the repository
    org.pentaho.di.core.database.DatabaseMeta
    loadDatabaseMetaFromJobEntryAttribute(org.pentaho.di.repository.ObjectId id_jobentry, String nameCode, int nr, String idCode, List<org.pentaho.di.core.database.DatabaseMeta> databases)
    This method is introduced to avoid having to go over an integer/string/whatever in the interface and the job entry code.
    org.pentaho.di.core.database.DatabaseMeta
    loadDatabaseMetaFromJobEntryAttribute(org.pentaho.di.repository.ObjectId id_jobentry, String nameCode, String idCode, List<org.pentaho.di.core.database.DatabaseMeta> databases)
    This method is introduced to avoid having to go over an integer/string/whatever in the interface and the job entry code.
    org.pentaho.di.core.database.DatabaseMeta
    loadDatabaseMetaFromStepAttribute(org.pentaho.di.repository.ObjectId id_step, String code, List<org.pentaho.di.core.database.DatabaseMeta> databases)
    This method is introduced to avoid having to go over an integer/string/whatever in the interface and the step code.
    JobMeta
    loadJob(String jobname, org.pentaho.di.repository.RepositoryDirectoryInterface repdir, org.pentaho.di.core.ProgressMonitorListener monitor, String revision)
    Load a job from the repository
    JobMeta
    loadJob(org.pentaho.di.repository.ObjectId id_job, String versionLabel)
    Load a job from the repository by id
    PartitionSchema
    loadPartitionSchema(org.pentaho.di.repository.ObjectId id_partition_schema, String versionLabel)
     
    org.pentaho.di.repository.RepositoryDirectoryInterface
    loadRepositoryDirectoryTree()
     
    SlaveServer
    loadSlaveServer(org.pentaho.di.repository.ObjectId id_slave_server, String versionLabel)
     
    TransMeta
    loadTransformation(String transname, org.pentaho.di.repository.RepositoryDirectoryInterface repdir, org.pentaho.di.core.ProgressMonitorListener monitor, boolean setInternalVariables, String revision)
    Load a transformation with a name from a folder in the repository
    TransMeta
    loadTransformation(org.pentaho.di.repository.ObjectId id_transformation, String versionLabel)
    Load a transformation by id
    List<org.pentaho.di.core.database.DatabaseMeta>
    readDatabases()
    Read all the databases defined in the repository
    SharedObjects
    readJobMetaSharedObjects(JobMeta jobMeta)
     
    SharedObjects
    readTransSharedObjects(TransMeta transMeta)
     
    org.pentaho.di.repository.ObjectId
    renameJob(org.pentaho.di.repository.ObjectId id_job, String versionComment, org.pentaho.di.repository.RepositoryDirectoryInterface newDirectory, String newName)
    Move / rename a job
    org.pentaho.di.repository.ObjectId
    renameJob(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.RepositoryDirectoryInterface newDirectory, String newName)
    Move / rename a job
    org.pentaho.di.repository.ObjectId
    renameRepositoryDirectory(org.pentaho.di.repository.ObjectId id, org.pentaho.di.repository.RepositoryDirectoryInterface newParentDir, String newName)
    Move / rename a repository directory
    org.pentaho.di.repository.ObjectId
    renameTransformation(org.pentaho.di.repository.ObjectId id_transformation, String versionComment, org.pentaho.di.repository.RepositoryDirectoryInterface newDirectory, String newName)
    Move / rename a transformation
    org.pentaho.di.repository.ObjectId
    renameTransformation(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.RepositoryDirectoryInterface newDirectory, String newName)
    Move / rename a transformation
    void
    save(org.pentaho.di.repository.RepositoryElementInterface repositoryElement, String versionComment, Calendar versionDate, org.pentaho.di.core.ProgressMonitorListener monitor, boolean overwrite)
    Save the object to the repository with version comments as well as version dates.
    void
    save(org.pentaho.di.repository.RepositoryElementInterface repositoryElement, String versionComment, org.pentaho.di.core.ProgressMonitorListener monitor)
     
    void
    save(org.pentaho.di.repository.RepositoryElementInterface repositoryElement, String versionComment, org.pentaho.di.core.ProgressMonitorListener monitor, boolean overwrite)
    Save an object to the repository optionally overwriting any associated objects.
    void
    saveConditionStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, String code, org.pentaho.di.core.Condition condition)
    This method saves the object ID of the condition object (if not null) in the step attributes
    void
    saveDatabaseMetaJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, int nr, String nameCode, String idCode, org.pentaho.di.core.database.DatabaseMeta database)
    This method saves the object ID of the database object (if not null) in the job entry attributes
    void
    saveDatabaseMetaJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, String nameCode, String idCode, org.pentaho.di.core.database.DatabaseMeta database)
    This method saves the object ID of the database object (if not null) in the job entry attributes
    void
    saveDatabaseMetaStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, String code, org.pentaho.di.core.database.DatabaseMeta database)
    This method saves the object ID of the database object (if not null) in the step attributes
    void
    saveJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, int nr, String code, boolean value)
     
    void
    saveJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, int nr, String code, long value)
     
    void
    saveJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, int nr, String code, String value)
     
    void
    saveJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, String code, boolean value)
     
    void
    saveJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, String code, long value)
     
    void
    saveJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, String code, String value)
     
    void
    saveRepositoryDirectory(org.pentaho.di.repository.RepositoryDirectoryInterface dir)
     
    void
    saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, int nr, String code, boolean value)
     
    void
    saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, int nr, String code, double value)
     
    void
    saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, int nr, String code, long value)
     
    void
    saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, int nr, String code, String value)
     
    void
    saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, String code, boolean value)
     
    void
    saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, String code, double value)
     
    void
    saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, String code, long value)
     
    void
    saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, String code, String value)
     
    void
    undeleteObject(org.pentaho.di.repository.RepositoryElementMetaInterface repositoryObject)
    Removes he deleted flag from a repository element in the repository.

  • Method Details

    • getName

      String getName()
      Returns:
      The name of the repository

    • getVersion

      String getVersion()
      Get the repository version.
      Returns:
      The repository version as a string

    • getRepositoryMeta

      RepositoryMeta getRepositoryMeta()
      Returns:
      the metadata describing this repository.

    • getUserInfo

      IUser getUserInfo()
      Returns:
      the currently logged on user. (also available through the repository security provider)

    • getSecurityProvider

      RepositorySecurityProvider getSecurityProvider()
      Returns:
      The security provider for this repository.

    • getSecurityManager

      RepositorySecurityManager getSecurityManager()
      Returns:
      The security manager for this repository.

    • getLog

      org.pentaho.di.core.logging.LogChannelInterface getLog()
      Returns:
      the logging channel of this repository

    • connect

      void connect(String username, String password) throws org.pentaho.di.core.exception.KettleException, org.pentaho.di.core.exception.KettleSecurityException
      Connect to the repository. Make sure you don't connect more than once to the same repository with this repository object.
      Parameters:
      username - the username of the user connecting to the repository.
      password - the password of the user connecting to the repository.
      Throws:
      org.pentaho.di.core.exception.KettleSecurityException - in case the supplied user or password is incorrect.
      org.pentaho.di.core.exception.KettleException - in case there is a general unexpected error OR if we're already connected to the repository.

    • disconnect

      void disconnect()
      Disconnect from the repository.

    • isConnected

      boolean isConnected()

    • getUri

      default Optional<URI> getUri()
      Returns the URI of the repository location, if defined by the implementation

    • init

      void init(RepositoryMeta repositoryMeta)
      Initialize the repository with the repository metadata and user information.

    • exists

      boolean exists(String name, org.pentaho.di.repository.RepositoryDirectoryInterface repositoryDirectory, org.pentaho.di.repository.RepositoryObjectType objectType) throws org.pentaho.di.core.exception.KettleException
      See if a repository object exists in the repository
      Parameters:
      name - the name of the object
      repositoryDirectory - the directory in which it should reside
      objectType - the type of repository object
      Returns:
      true if the job exists
      Throws:
      org.pentaho.di.core.exception.KettleException - in case something goes wrong.

    • getTransformationID

      org.pentaho.di.repository.ObjectId getTransformationID(String name, org.pentaho.di.repository.RepositoryDirectoryInterface repositoryDirectory) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getJobId

      org.pentaho.di.repository.ObjectId getJobId(String name, org.pentaho.di.repository.RepositoryDirectoryInterface repositoryDirectory) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • save

      void save(org.pentaho.di.repository.RepositoryElementInterface repositoryElement, String versionComment, org.pentaho.di.core.ProgressMonitorListener monitor) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • save

      void save(org.pentaho.di.repository.RepositoryElementInterface repositoryElement, String versionComment, org.pentaho.di.core.ProgressMonitorListener monitor, boolean overwrite) throws org.pentaho.di.core.exception.KettleException
      Save an object to the repository optionally overwriting any associated objects.
      Parameters:
      repositoryElement - Object to save
      versionComment - Version comment for update
      monitor - Progress Monitor to report feedback to
      overwrite - Overwrite any existing objects involved in saving repositoryElement, e.g. repositoryElement, database connections, slave servers
      Throws:
      org.pentaho.di.core.exception.KettleException - Error saving the object to the repository

    • save

      void save(org.pentaho.di.repository.RepositoryElementInterface repositoryElement, String versionComment, Calendar versionDate, org.pentaho.di.core.ProgressMonitorListener monitor, boolean overwrite) throws org.pentaho.di.core.exception.KettleException
      Save the object to the repository with version comments as well as version dates. This form exists largely to support the importing of revisions, preserving their revision date.
      Parameters:
      repositoryElement -
      versionComment -
      versionDate -
      monitor -
      overwrite -
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getDefaultSaveDirectory

      org.pentaho.di.repository.RepositoryDirectoryInterface getDefaultSaveDirectory(org.pentaho.di.repository.RepositoryElementInterface repositoryElement) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getUserHomeDirectory

      org.pentaho.di.repository.RepositoryDirectoryInterface getUserHomeDirectory() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • clearSharedObjectCache

      void clearSharedObjectCache()
      Clear the shared object cache, if applicable.

    • loadTransformation

      TransMeta loadTransformation(String transname, org.pentaho.di.repository.RepositoryDirectoryInterface repdir, org.pentaho.di.core.ProgressMonitorListener monitor, boolean setInternalVariables, String revision) throws org.pentaho.di.core.exception.KettleException
      Load a transformation with a name from a folder in the repository
      Parameters:
      transname - the name of the transformation to load
      The - folder to load it from
      monitor - the progress monitor to use (UI feedback)
      setInternalVariables - set to true if you want to automatically set the internal variables of the loaded transformation. (true is the default with very few exceptions!)
      revision - the revision to load. Specify null to load the last version.
      Throws:
      org.pentaho.di.core.exception.KettleException

    • loadTransformation

      TransMeta loadTransformation(org.pentaho.di.repository.ObjectId id_transformation, String versionLabel) throws org.pentaho.di.core.exception.KettleException
      Load a transformation by id
      Parameters:
      id_transformation - the id of the transformation to load
      versionLabel - version to load. Specify null to load the last version.
      Throws:
      org.pentaho.di.core.exception.KettleException

    • readTransSharedObjects

      SharedObjects readTransSharedObjects(TransMeta transMeta) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • renameTransformation

      org.pentaho.di.repository.ObjectId renameTransformation(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.RepositoryDirectoryInterface newDirectory, String newName) throws org.pentaho.di.core.exception.KettleException
      Move / rename a transformation
      Parameters:
      id_transformation - The ObjectId of the transformation to move
      newDirectory - The RepositoryDirectoryInterface that will be the new parent of the transformation (May be null if a move is not desired)
      newName - The new name of the transformation (May be null if a rename is not desired)
      Returns:
      The ObjectId of the transformation that was moved
      Throws:
      org.pentaho.di.core.exception.KettleException

    • renameTransformation

      org.pentaho.di.repository.ObjectId renameTransformation(org.pentaho.di.repository.ObjectId id_transformation, String versionComment, org.pentaho.di.repository.RepositoryDirectoryInterface newDirectory, String newName) throws org.pentaho.di.core.exception.KettleException
      Move / rename a transformation
      Parameters:
      id_transformation - The ObjectId of the transformation to move
      versionComment - Version comment for rename
      newDirectory - The RepositoryDirectoryInterface that will be the new parent of the transformation (May be null if a move is not desired)
      newName - The new name of the transformation (May be null if a rename is not desired)
      Returns:
      The ObjectId of the transformation that was moved
      Throws:
      org.pentaho.di.core.exception.KettleException

    • deleteTransformation

      void deleteTransformation(org.pentaho.di.repository.ObjectId id_transformation) throws org.pentaho.di.core.exception.KettleException
      Delete everything related to a transformation from the repository. This does not included shared objects : databases, slave servers, cluster and partition schema.
      Parameters:
      id_transformation - the transformation id to delete
      Throws:
      org.pentaho.di.core.exception.KettleException

    • loadJob

      JobMeta loadJob(String jobname, org.pentaho.di.repository.RepositoryDirectoryInterface repdir, org.pentaho.di.core.ProgressMonitorListener monitor, String revision) throws org.pentaho.di.core.exception.KettleException
      Load a job from the repository
      Parameters:
      jobname - the name
      repdir - the directory
      monitor - the progress monitor or null
      revision - the revision to load. Specify null to load the last version.
      Throws:
      org.pentaho.di.core.exception.KettleException

    • loadJob

      JobMeta loadJob(org.pentaho.di.repository.ObjectId id_job, String versionLabel) throws org.pentaho.di.core.exception.KettleException
      Load a job from the repository by id
      Parameters:
      id_job - the id of the job
      versionLabel - version to load. Specify null to load the last version.
      Throws:
      org.pentaho.di.core.exception.KettleException

    • readJobMetaSharedObjects

      SharedObjects readJobMetaSharedObjects(JobMeta jobMeta) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • renameJob

      org.pentaho.di.repository.ObjectId renameJob(org.pentaho.di.repository.ObjectId id_job, String versionComment, org.pentaho.di.repository.RepositoryDirectoryInterface newDirectory, String newName) throws org.pentaho.di.core.exception.KettleException
      Move / rename a job
      Parameters:
      id_job - The ObjectId of the job to move
      versionComment - Version comment for rename
      newDirectory - The RepositoryDirectoryInterface that will be the new parent of the job (May be null if a move is not desired)
      newName - The new name of the job (May be null if a rename is not desired)
      Returns:
      The ObjectId of the job that was moved
      Throws:
      org.pentaho.di.core.exception.KettleException

    • renameJob

      org.pentaho.di.repository.ObjectId renameJob(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.RepositoryDirectoryInterface newDirectory, String newName) throws org.pentaho.di.core.exception.KettleException
      Move / rename a job
      Parameters:
      id_job - The ObjectId of the job to move
      newDirectory - The RepositoryDirectoryInterface that will be the new parent of the job (May be null if a move is not desired)
      newName - The new name of the job (May be null if a rename is not desired)
      Returns:
      The ObjectId of the job that was moved
      Throws:
      org.pentaho.di.core.exception.KettleException

    • deleteJob

      void deleteJob(org.pentaho.di.repository.ObjectId id_job) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • loadDatabaseMeta

      org.pentaho.di.core.database.DatabaseMeta loadDatabaseMeta(org.pentaho.di.repository.ObjectId id_database, String revision) throws org.pentaho.di.core.exception.KettleException
      Load the Database connection Metadata from the repository
      Parameters:
      id_database - the id of the database connection to load
      revision - the revision to load. Specify null to load the last version.
      Throws:
      org.pentaho.di.core.exception.KettleException - in case something goes wrong with database, connection, etc.

    • deleteDatabaseMeta

      void deleteDatabaseMeta(String databaseName) throws org.pentaho.di.core.exception.KettleException
      Remove a database connection from the repository
      Parameters:
      databaseName - The name of the connection to remove
      Throws:
      org.pentaho.di.core.exception.KettleException - In case something went wrong: database error, insufficient permissions, depending objects, etc.

    • getDatabaseIDs

      org.pentaho.di.repository.ObjectId[] getDatabaseIDs(boolean includeDeleted) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getDatabaseNames

      String[] getDatabaseNames(boolean includeDeleted) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • readDatabases

      List<org.pentaho.di.core.database.DatabaseMeta> readDatabases() throws org.pentaho.di.core.exception.KettleException
      Read all the databases defined in the repository
      Returns:
      a list of all the databases defined in the repository
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getDatabaseID

      org.pentaho.di.repository.ObjectId getDatabaseID(String name) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • loadClusterSchema

      ClusterSchema loadClusterSchema(org.pentaho.di.repository.ObjectId id_cluster_schema, List<SlaveServer> slaveServers, String versionLabel) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getClusterIDs

      org.pentaho.di.repository.ObjectId[] getClusterIDs(boolean includeDeleted) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getClusterNames

      String[] getClusterNames(boolean includeDeleted) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getClusterID

      org.pentaho.di.repository.ObjectId getClusterID(String name) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • deleteClusterSchema

      void deleteClusterSchema(org.pentaho.di.repository.ObjectId id_cluster) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • loadSlaveServer

      SlaveServer loadSlaveServer(org.pentaho.di.repository.ObjectId id_slave_server, String versionLabel) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getSlaveIDs

      org.pentaho.di.repository.ObjectId[] getSlaveIDs(boolean includeDeleted) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getSlaveNames

      String[] getSlaveNames(boolean includeDeleted) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getSlaveServers

      List<SlaveServer> getSlaveServers() throws org.pentaho.di.core.exception.KettleException
      Returns:
      a list of all the slave servers in the repository.
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getSlaveID

      org.pentaho.di.repository.ObjectId getSlaveID(String name) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • deleteSlave

      void deleteSlave(org.pentaho.di.repository.ObjectId id_slave) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • loadPartitionSchema

      PartitionSchema loadPartitionSchema(org.pentaho.di.repository.ObjectId id_partition_schema, String versionLabel) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getPartitionSchemaIDs

      org.pentaho.di.repository.ObjectId[] getPartitionSchemaIDs(boolean includeDeleted) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getPartitionSchemaNames

      String[] getPartitionSchemaNames(boolean includeDeleted) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getPartitionSchemaID

      org.pentaho.di.repository.ObjectId getPartitionSchemaID(String name) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • deletePartitionSchema

      void deletePartitionSchema(org.pentaho.di.repository.ObjectId id_partition_schema) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • loadRepositoryDirectoryTree

      org.pentaho.di.repository.RepositoryDirectoryInterface loadRepositoryDirectoryTree() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • findDirectory

      org.pentaho.di.repository.RepositoryDirectoryInterface findDirectory(String directory) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • findDirectory

      org.pentaho.di.repository.RepositoryDirectoryInterface findDirectory(org.pentaho.di.repository.ObjectId directory) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • saveRepositoryDirectory

      void saveRepositoryDirectory(org.pentaho.di.repository.RepositoryDirectoryInterface dir) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • deleteRepositoryDirectory

      void deleteRepositoryDirectory(org.pentaho.di.repository.RepositoryDirectoryInterface dir) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • renameRepositoryDirectory

      org.pentaho.di.repository.ObjectId renameRepositoryDirectory(org.pentaho.di.repository.ObjectId id, org.pentaho.di.repository.RepositoryDirectoryInterface newParentDir, String newName) throws org.pentaho.di.core.exception.KettleException
      Move / rename a repository directory
      Parameters:
      id - The ObjectId of the repository directory to move
      newParentDir - The RepositoryDirectoryInterface that will be the new parent of the repository directory (May be null if a move is not desired)
      newName - The new name of the repository directory (May be null if a rename is not desired)
      Returns:
      The ObjectId of the repository directory that was moved
      Throws:
      org.pentaho.di.core.exception.KettleException

    • createRepositoryDirectory

      org.pentaho.di.repository.RepositoryDirectoryInterface createRepositoryDirectory(org.pentaho.di.repository.RepositoryDirectoryInterface parentDirectory, String directoryPath) throws org.pentaho.di.core.exception.KettleException
      Create a new directory, possibly by creating several sub-directies of / at the same time.
      Parameters:
      parentDirectory - the parent directory
      directoryPath - The partial path to the new Repository Directory, to be created.
      Returns:
      The created sub-directory
      Throws:
      org.pentaho.di.core.exception.KettleException - In case something goes wrong

    • getTransformationNames

      String[] getTransformationNames(org.pentaho.di.repository.ObjectId id_directory, boolean includeDeleted) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getJobObjects

      List<org.pentaho.di.repository.RepositoryElementMetaInterface> getJobObjects(org.pentaho.di.repository.ObjectId id_directory, boolean includeDeleted) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getTransformationObjects

      List<org.pentaho.di.repository.RepositoryElementMetaInterface> getTransformationObjects(org.pentaho.di.repository.ObjectId id_directory, boolean includeDeleted) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getJobAndTransformationObjects

      List<org.pentaho.di.repository.RepositoryElementMetaInterface> getJobAndTransformationObjects(org.pentaho.di.repository.ObjectId id_directory, boolean includeDeleted) throws org.pentaho.di.core.exception.KettleException
      Gets all job and transformation objects in the given directory. (Combines getJobObjects(ObjectId, boolean) and getTransformationObjects(ObjectId, boolean) into one operation.
      Parameters:
      id_directory - directory
      includeDeleted - true to return deleted objects
      Returns:
      list of repository objects
      Throws:
      org.pentaho.di.core.exception.KettleException - In case something goes wrong

    • getJobNames

      String[] getJobNames(org.pentaho.di.repository.ObjectId id_directory, boolean includeDeleted) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getDirectoryNames

      String[] getDirectoryNames(org.pentaho.di.repository.ObjectId id_directory) throws org.pentaho.di.core.exception.KettleException
      Returns the child directory names of a parent directory
      Parameters:
      id_directory - parent directory id
      Returns:
      array of child names
      Throws:
      org.pentaho.di.core.exception.KettleException

    • insertLogEntry

      org.pentaho.di.repository.ObjectId insertLogEntry(String description) throws org.pentaho.di.core.exception.KettleException
      Insert an entry in the audit trail of the repository. This is an optional operation and depends on the capabilities of the underlying repository.
      Parameters:
      The - description to be put in the audit trail of the repository.
      Throws:
      org.pentaho.di.core.exception.KettleException

    • insertStepDatabase

      void insertStepDatabase(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, org.pentaho.di.repository.ObjectId id_database) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • insertJobEntryDatabase

      void insertJobEntryDatabase(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, org.pentaho.di.repository.ObjectId id_database) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • saveConditionStepAttribute

      void saveConditionStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, String code, org.pentaho.di.core.Condition condition) throws org.pentaho.di.core.exception.KettleException
      This method saves the object ID of the condition object (if not null) in the step attributes
      Parameters:
      id_step -
      code -
      condition -
      Throws:
      org.pentaho.di.core.exception.KettleException

    • loadConditionFromStepAttribute

      org.pentaho.di.core.Condition loadConditionFromStepAttribute(org.pentaho.di.repository.ObjectId id_step, String code) throws org.pentaho.di.core.exception.KettleException
      Load a condition from the repository with the Object ID stored in a step attribute.
      Parameters:
      id_step -
      code -
      Returns:
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getStepAttributeBoolean

      boolean getStepAttributeBoolean(org.pentaho.di.repository.ObjectId id_step, int nr, String code, boolean def) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getStepAttributeBoolean

      boolean getStepAttributeBoolean(org.pentaho.di.repository.ObjectId id_step, int nr, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getStepAttributeBoolean

      boolean getStepAttributeBoolean(org.pentaho.di.repository.ObjectId id_step, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getStepAttributeInteger

      long getStepAttributeInteger(org.pentaho.di.repository.ObjectId id_step, int nr, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getStepAttributeInteger

      long getStepAttributeInteger(org.pentaho.di.repository.ObjectId id_step, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getStepAttributeString

      String getStepAttributeString(org.pentaho.di.repository.ObjectId id_step, int nr, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getStepAttributeString

      String getStepAttributeString(org.pentaho.di.repository.ObjectId id_step, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • saveStepAttribute

      void saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, int nr, String code, String value) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • saveStepAttribute

      void saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, String code, String value) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • saveStepAttribute

      void saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, int nr, String code, boolean value) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • saveStepAttribute

      void saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, String code, boolean value) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • saveStepAttribute

      void saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, int nr, String code, long value) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • saveStepAttribute

      void saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, String code, long value) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • saveStepAttribute

      void saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, int nr, String code, double value) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • saveStepAttribute

      void saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, String code, double value) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • countNrStepAttributes

      int countNrStepAttributes(org.pentaho.di.repository.ObjectId id_step, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • countNrJobEntryAttributes

      int countNrJobEntryAttributes(org.pentaho.di.repository.ObjectId id_jobentry, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getJobEntryAttributeBoolean

      boolean getJobEntryAttributeBoolean(org.pentaho.di.repository.ObjectId id_jobentry, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getJobEntryAttributeBoolean

      boolean getJobEntryAttributeBoolean(org.pentaho.di.repository.ObjectId id_jobentry, int nr, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getJobEntryAttributeBoolean

      boolean getJobEntryAttributeBoolean(org.pentaho.di.repository.ObjectId id_jobentry, String code, boolean def) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getJobEntryAttributeInteger

      long getJobEntryAttributeInteger(org.pentaho.di.repository.ObjectId id_jobentry, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getJobEntryAttributeInteger

      long getJobEntryAttributeInteger(org.pentaho.di.repository.ObjectId id_jobentry, int nr, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getJobEntryAttributeString

      String getJobEntryAttributeString(org.pentaho.di.repository.ObjectId id_jobentry, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getJobEntryAttributeString

      String getJobEntryAttributeString(org.pentaho.di.repository.ObjectId id_jobentry, int nr, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • saveJobEntryAttribute

      void saveJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, int nr, String code, String value) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • saveJobEntryAttribute

      void saveJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, String code, String value) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • saveJobEntryAttribute

      void saveJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, int nr, String code, boolean value) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • saveJobEntryAttribute

      void saveJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, String code, boolean value) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • saveJobEntryAttribute

      void saveJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, int nr, String code, long value) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • saveJobEntryAttribute

      void saveJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, String code, long value) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • loadDatabaseMetaFromStepAttribute

      org.pentaho.di.core.database.DatabaseMeta loadDatabaseMetaFromStepAttribute(org.pentaho.di.repository.ObjectId id_step, String code, List<org.pentaho.di.core.database.DatabaseMeta> databases) throws org.pentaho.di.core.exception.KettleException
      This method is introduced to avoid having to go over an integer/string/whatever in the interface and the step code.
      Parameters:
      id_step -
      code -
      Returns:
      Throws:
      org.pentaho.di.core.exception.KettleException

    • saveDatabaseMetaStepAttribute

      void saveDatabaseMetaStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, String code, org.pentaho.di.core.database.DatabaseMeta database) throws org.pentaho.di.core.exception.KettleException
      This method saves the object ID of the database object (if not null) in the step attributes
      Parameters:
      id_transformation -
      id_step -
      code -
      database -
      Throws:
      org.pentaho.di.core.exception.KettleException

    • loadDatabaseMetaFromJobEntryAttribute

      org.pentaho.di.core.database.DatabaseMeta loadDatabaseMetaFromJobEntryAttribute(org.pentaho.di.repository.ObjectId id_jobentry, String nameCode, String idCode, List<org.pentaho.di.core.database.DatabaseMeta> databases) throws org.pentaho.di.core.exception.KettleException
      This method is introduced to avoid having to go over an integer/string/whatever in the interface and the job entry code.
      Parameters:
      id_step -
      code -
      Returns:
      Throws:
      org.pentaho.di.core.exception.KettleException

    • loadDatabaseMetaFromJobEntryAttribute

      org.pentaho.di.core.database.DatabaseMeta loadDatabaseMetaFromJobEntryAttribute(org.pentaho.di.repository.ObjectId id_jobentry, String nameCode, int nr, String idCode, List<org.pentaho.di.core.database.DatabaseMeta> databases) throws org.pentaho.di.core.exception.KettleException
      This method is introduced to avoid having to go over an integer/string/whatever in the interface and the job entry code.
      Parameters:
      id_entry -
      nameCode -
      nr -
      idcode -
      databases -
      Returns:
      Throws:
      org.pentaho.di.core.exception.KettleException

    • saveDatabaseMetaJobEntryAttribute

      void saveDatabaseMetaJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, String nameCode, String idCode, org.pentaho.di.core.database.DatabaseMeta database) throws org.pentaho.di.core.exception.KettleException
      This method saves the object ID of the database object (if not null) in the job entry attributes
      Parameters:
      id_job -
      id_jobentry -
      idCode -
      database -
      Throws:
      org.pentaho.di.core.exception.KettleException

    • saveDatabaseMetaJobEntryAttribute

      void saveDatabaseMetaJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, int nr, String nameCode, String idCode, org.pentaho.di.core.database.DatabaseMeta database) throws org.pentaho.di.core.exception.KettleException
      This method saves the object ID of the database object (if not null) in the job entry attributes
      Parameters:
      id_job -
      id_jobentry -
      nr -
      code -
      database -
      Throws:
      org.pentaho.di.core.exception.KettleException

    • undeleteObject

      void undeleteObject(org.pentaho.di.repository.RepositoryElementMetaInterface repositoryObject) throws org.pentaho.di.core.exception.KettleException
      Removes he deleted flag from a repository element in the repository. If it wasn't deleted, it remains untouched.
      Parameters:
      element - the repository element to restore
      Throws:
      org.pentaho.di.core.exception.KettleException - get throws in case something goes horribly wrong.

    • getServiceInterfaces

      List<Class<? extends IRepositoryService>> getServiceInterfaces() throws org.pentaho.di.core.exception.KettleException
      Retrieves the current list of of IRepository Services.
      Returns:
      List of repository services
      Throws:
      org.pentaho.di.core.exception.KettleException - in case something goes horribly wrong.

    • getService

      IRepositoryService getService(Class<? extends IRepositoryService> clazz) throws org.pentaho.di.core.exception.KettleException
      Retrieves a given repository service
      Parameters:
      service - class name
      Returns:
      repository service
      Throws:
      org.pentaho.di.core.exception.KettleException - in case something goes horribly wrong.

    • hasService

      boolean hasService(Class<? extends IRepositoryService> clazz) throws org.pentaho.di.core.exception.KettleException
      Checks whether a given repository service is available or not
      Parameters:
      repository - service class that needs to be checked for support
      Throws:
      org.pentaho.di.core.exception.KettleException - in case something goes horribly wrong.

    • getObjectInformation

      RepositoryObject getObjectInformation(org.pentaho.di.repository.ObjectId objectId, org.pentaho.di.repository.RepositoryObjectType objectType) throws org.pentaho.di.core.exception.KettleException
      Get more information about a certain object ID in the form of the RepositoryObject
      Parameters:
      objectId - The ID of the object to get more information about.
      objectType - The type of object to investigate.
      Returns:
      The repository object or null if nothing could be found.
      Throws:
      org.pentaho.di.core.exception.KettleException - In case there was a loading problem.

    • getConnectMessage

      String getConnectMessage()
      This is an informational message that a repository can display on connecting within Spoon. If a null is returned, no message is displayed to the end user.
      Returns:
      message

    • getJobsUsingDatabase

      String[] getJobsUsingDatabase(org.pentaho.di.repository.ObjectId id_database) throws org.pentaho.di.core.exception.KettleException
      Get the repository version.
      Returns:
      The repository version as a string
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getTransformationsUsingDatabase

      String[] getTransformationsUsingDatabase(org.pentaho.di.repository.ObjectId id_database) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getImporter

      IRepositoryImporter getImporter()
      Returns:
      the importer that will handle imports into this repository

    • getExporter

      IRepositoryExporter getExporter() throws org.pentaho.di.core.exception.KettleException
      Returns:
      the exporter that will handle exports from this repository
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getRepositoryMetaStore

      org.pentaho.metastore.api.IMetaStore getRepositoryMetaStore()
      Returns:
      the Metastore that is implemented in this Repository. Return null if this repository doesn't implement a Metastore. This should only be used when you want a specific repository instance (see RepositoryMetastoreProvider), for all generic metastore usage use MetaStoreConst.getDefaultMetastore()

    • getUnderlyingRepository

      org.pentaho.platform.api.repository2.unified.IUnifiedRepository getUnderlyingRepository()
      Returns:
      repository for connect to server