org.pentaho.di.repository.filerep
Class KettleFileRepository

java.lang.Object
  org.pentaho.di.repository.filerep.KettleFileRepository

All Implemented Interfaces:

Repository

public class KettleFileRepository
extends Object
implements Repository

Field Summary

static String

FILE_REPOSITORY_VERSION

Constructor Summary

KettleFileRepository()

Method Summary

String	calcFilename(org.pentaho.di.repository.ObjectId id)
String	calcObjectId(org.pentaho.di.repository.RepositoryDirectoryInterface dir)
String	calcObjectId(org.pentaho.di.repository.RepositoryDirectoryInterface directory, String name, String extension)
String	calcObjectId(org.pentaho.di.repository.RepositoryElementInterface element)
String	calcRelativeElementDirectory(org.pentaho.di.repository.RepositoryDirectoryInterface dir)
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	deleteCondition(org.pentaho.di.repository.ObjectId id_condition)
void	deleteDatabaseMeta(String databaseName) Remove a database connection from the repository
void	deleteFile(String filename)
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	deleteRootObject(String name, String extension)
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	delUser(org.pentaho.di.repository.ObjectId id_user)
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(org.pentaho.di.repository.ObjectId directory)
org.pentaho.di.repository.RepositoryDirectoryInterface	findDirectory(String directory)
org.pentaho.di.repository.ObjectId	getClusterID(String name)
org.pentaho.di.repository.ObjectId[]	getClusterIDs(boolean includeDeleted)
String[]	getClusterNames(boolean includeDeleted)
org.pentaho.di.repository.ObjectId[]	getClusterSlaveIDs(org.pentaho.di.repository.ObjectId id_cluster_schema)
String[]	getClustersUsingSlave(org.pentaho.di.repository.ObjectId id_slave)
String	getConnectMessage() This is an informational message that a repository can display on connecting within Spoon.
org.pentaho.di.repository.ObjectId[]	getDatabaseAttributeIDs(org.pentaho.di.repository.ObjectId id_database)
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)
org.pentaho.di.repository.ObjectId[]	getJobNoteIDs(org.pentaho.di.repository.ObjectId id_job)
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()
int	getNrSubDirectories(org.pentaho.di.repository.ObjectId id_directory)
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)
KettleFileRepositoryMeta	getRepositoryMeta()
org.pentaho.di.repository.ObjectId	getRootDirectoryID()
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[]	getSubConditionIDs(org.pentaho.di.repository.ObjectId id_condition)
org.pentaho.di.repository.ObjectId[]	getSubDirectoryIDs(org.pentaho.di.repository.ObjectId id_directory)
org.pentaho.di.repository.ObjectId[]	getTransformationClusterSchemaIDs(org.pentaho.di.repository.ObjectId id_transformation)
org.pentaho.di.repository.ObjectId[]	getTransformationConditionIDs(org.pentaho.di.repository.ObjectId id_transformation)
org.pentaho.di.repository.ObjectId[]	getTransformationDatabaseIDs(org.pentaho.di.repository.ObjectId id_transformation)
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 idDirectory, boolean includeDeleted)
org.pentaho.di.repository.ObjectId[]	getTransformationPartitionSchemaIDs(org.pentaho.di.repository.ObjectId id_transformation)
String[]	getTransformationsUsingCluster(org.pentaho.di.repository.ObjectId id_cluster)
String[]	getTransformationsUsingDatabase(org.pentaho.di.repository.ObjectId id_database)
String[]	getTransformationsUsingPartitionSchema(org.pentaho.di.repository.ObjectId id_partition_schema)
String[]	getTransformationsUsingSlave(org.pentaho.di.repository.ObjectId id_slave)
org.pentaho.di.repository.ObjectId[]	getTransNoteIDs(org.pentaho.di.repository.ObjectId id_transformation)
org.pentaho.di.repository.RepositoryDirectoryInterface	getUserHomeDirectory()
org.pentaho.di.repository.ObjectId	getUserID(String login)
org.pentaho.di.repository.ObjectId[]	getUserIDs()
IUser	getUserInfo()
String[]	getUserLogins()
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.
org.pentaho.di.repository.ObjectId	insertClusterSlave(ClusterSchema clusterSchema, SlaveServer slaveServer)
void	insertJobEntryDatabase(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, org.pentaho.di.repository.ObjectId id_database)
void	insertJobNote(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_note)
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)
org.pentaho.di.repository.ObjectId	insertTransformationCluster(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_cluster)
org.pentaho.di.repository.ObjectId	insertTransformationPartitionSchema(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_partition_schema)
org.pentaho.di.repository.ObjectId	insertTransformationSlave(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_slave)
void	insertTransNote(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_note)
void	insertTransStepCondition(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, org.pentaho.di.repository.ObjectId id_condition)
boolean	isConnected()
ClusterSchema	loadClusterSchema(org.pentaho.di.repository.ObjectId id_cluster_schema, List<SlaveServer> slaveServers, String versionName)
Condition	loadCondition(org.pentaho.di.repository.ObjectId id_condition)
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 versionName) Load the Database connection Metadata from the repository
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(org.pentaho.di.repository.ObjectId idJob, String versionLabel) Load a job from the repository by id
JobMeta	loadJob(String jobname, org.pentaho.di.repository.RepositoryDirectoryInterface repdir, org.pentaho.di.core.ProgressMonitorListener monitor, String versionName) Load a job from the repository
Node	loadNodeFromXML(org.pentaho.di.repository.ObjectId id, String tag)
PartitionSchema	loadPartitionSchema(org.pentaho.di.repository.ObjectId id_partition_schema, String versionName)
org.pentaho.di.repository.RepositoryDirectoryInterface	loadRepositoryDirectoryTree()
org.pentaho.di.repository.RepositoryDirectoryInterface	loadRepositoryDirectoryTree(org.pentaho.di.repository.RepositoryDirectoryInterface dir)
SlaveServer	loadSlaveServer(org.pentaho.di.repository.ObjectId id_slave_server, String versionName)
TransMeta	loadTransformation(org.pentaho.di.repository.ObjectId idTransformation, String versionLabel) Load a transformation by id
TransMeta	loadTransformation(String transname, org.pentaho.di.repository.RepositoryDirectoryInterface repdir, org.pentaho.di.core.ProgressMonitorListener monitor, boolean setInternalVariables, String versionName) Load a transformation with a name from a folder in the repository
UserInfo	loadUserInfo(String login)
UserInfo	loadUserInfo(String login, String password)
org.pentaho.di.core.row.ValueMetaAndData	loadValueMetaAndData(org.pentaho.di.repository.ObjectId id_value)
void	moveJob(String jobname, org.pentaho.di.repository.ObjectId id_directory_from, org.pentaho.di.repository.ObjectId id_directory_to)
void	moveTransformation(String transname, org.pentaho.di.repository.ObjectId id_directory_from, org.pentaho.di.repository.ObjectId id_directory_to)
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, org.pentaho.di.repository.RepositoryDirectoryInterface newDir, 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, org.pentaho.di.repository.RepositoryDirectoryInterface newDir, String newName) Move / rename a transformation
void	renameUser(org.pentaho.di.repository.ObjectId id_user, String newname)
void	save(org.pentaho.di.repository.RepositoryElementInterface repositoryElement, String versionComment)
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	save(org.pentaho.di.repository.RepositoryElementInterface repositoryElement, String versionComment, org.pentaho.di.core.ProgressMonitorListener monitor, org.pentaho.di.repository.ObjectId parentId, boolean used)
org.pentaho.di.repository.ObjectId	saveCondition(Condition condition)
org.pentaho.di.repository.ObjectId	saveCondition(Condition condition, org.pentaho.di.repository.ObjectId id_condition_parent)
void	saveConditionStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, String code, 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, String code, org.pentaho.di.core.database.DatabaseMeta database)
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	saveUserInfo(UserInfo userInfo)
void	setRepositoryMeta(KettleFileRepositoryMeta repositoryMeta)
void	undeleteObject(org.pentaho.di.repository.RepositoryElementMetaInterface repositoryObject) Removes he deleted flag from a repository element in the repository.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

FILE_REPOSITORY_VERSION

public static final String FILE_REPOSITORY_VERSION

See Also:

Constant Field Values

Constructor Detail

KettleFileRepository

public KettleFileRepository()

Method Detail

connect

public void connect(String username,
                    String password)
             throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Connect to the repository. Make sure you don't connect more than once to the same repository with this repository object.

Specified by:

connect in interface Repository

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

public void disconnect()

Description copied from interface: Repository

Disconnect from the repository.

Specified by:

disconnect in interface Repository

init

public void init(RepositoryMeta repositoryMeta)

Description copied from interface: Repository

Initialize the repository with the repository metadata and user information.

Specified by:

init in interface Repository

getLog

public org.pentaho.di.core.logging.LogChannelInterface getLog()

Specified by:

getLog in interface Repository

Returns:

the logging channel of this repository

isConnected

public boolean isConnected()

Specified by:

isConnected in interface Repository

getSecurityProvider

public RepositorySecurityProvider getSecurityProvider()

Specified by:

getSecurityProvider in interface Repository

Returns:

The security provider for this repository.

getSecurityManager

public RepositorySecurityManager getSecurityManager()

Specified by:

getSecurityManager in interface Repository

Returns:

The security manager for this repository.

calcRelativeElementDirectory

public String calcRelativeElementDirectory(org.pentaho.di.repository.RepositoryDirectoryInterface dir)

calcObjectId

public String calcObjectId(org.pentaho.di.repository.RepositoryDirectoryInterface dir)

calcObjectId

public String calcObjectId(org.pentaho.di.repository.RepositoryDirectoryInterface directory,
                           String name,
                           String extension)

calcObjectId

public String calcObjectId(org.pentaho.di.repository.RepositoryElementInterface element)

calcFilename

public String calcFilename(org.pentaho.di.repository.ObjectId id)

exists

public boolean exists(String name,
                      org.pentaho.di.repository.RepositoryDirectoryInterface repositoryDirectory,
                      org.pentaho.di.repository.RepositoryObjectType objectType)
               throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

See if a repository object exists in the repository

Specified by:

exists in interface 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.

save

public void save(org.pentaho.di.repository.RepositoryElementInterface repositoryElement,
                 String versionComment)
          throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

save

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

Specified by:

save in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

save

public 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

Description copied from interface: Repository

Save an object to the repository optionally overwriting any associated objects.

Specified by:

save in interface Repository

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

public void save(org.pentaho.di.repository.RepositoryElementInterface repositoryElement,
                 String versionComment,
                 org.pentaho.di.core.ProgressMonitorListener monitor,
                 org.pentaho.di.repository.ObjectId parentId,
                 boolean used)
          throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

createRepositoryDirectory

public org.pentaho.di.repository.RepositoryDirectoryInterface createRepositoryDirectory(org.pentaho.di.repository.RepositoryDirectoryInterface parentDirectory,
                                                                                        String directoryPath)
                                                                                 throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Create a new directory, possibly by creating several sub-directies of / at the same time.

Specified by:

createRepositoryDirectory in interface Repository

Parameters:

parentDirectory - the parent directory

directoryPath - The 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

saveRepositoryDirectory

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

Specified by:

saveRepositoryDirectory in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

deleteJob

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

Specified by:

deleteJob in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

deleteTransformation

public void deleteTransformation(org.pentaho.di.repository.ObjectId id_transformation)
                          throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Delete everything related to a transformation from the repository. This does not included shared objects : databases, slave servers, cluster and partition schema.

Specified by:

deleteTransformation in interface Repository

Parameters:

id_transformation - the transformation id to delete

Throws:

org.pentaho.di.core.exception.KettleException

deleteClusterSchema

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

Specified by:

deleteClusterSchema in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

deleteCondition

public void deleteCondition(org.pentaho.di.repository.ObjectId id_condition)
                     throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

deletePartitionSchema

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

Specified by:

deletePartitionSchema in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

deleteRepositoryDirectory

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

Specified by:

deleteRepositoryDirectory in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

deleteSlave

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

Specified by:

deleteSlave in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

deleteDatabaseMeta

public void deleteDatabaseMeta(String databaseName)
                        throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Remove a database connection from the repository

Specified by:

deleteDatabaseMeta in interface 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.

deleteRootObject

public void deleteRootObject(String name,
                             String extension)
                      throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

deleteFile

public void deleteFile(String filename)
                throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getClusterID

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

Specified by:

getClusterID in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getClusterIDs

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

Specified by:

getClusterIDs in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getClusterNames

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

Specified by:

getClusterNames in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getClustersUsingSlave

public String[] getClustersUsingSlave(org.pentaho.di.repository.ObjectId id_slave)
                               throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getTransformationConditionIDs

public org.pentaho.di.repository.ObjectId[] getTransformationConditionIDs(org.pentaho.di.repository.ObjectId id_transformation)
                                                                   throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getDatabaseAttributeIDs

public org.pentaho.di.repository.ObjectId[] getDatabaseAttributeIDs(org.pentaho.di.repository.ObjectId id_database)
                                                             throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getDatabaseID

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

Specified by:

getDatabaseID in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getTransformationDatabaseIDs

public org.pentaho.di.repository.ObjectId[] getTransformationDatabaseIDs(org.pentaho.di.repository.ObjectId id_transformation)
                                                                  throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getDatabaseIDs

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

Specified by:

getDatabaseIDs in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getDatabaseNames

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

Specified by:

getDatabaseNames in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getDirectoryNames

public String[] getDirectoryNames(org.pentaho.di.repository.ObjectId id_directory)
                           throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Returns the child directory names of a parent directory

Specified by:

getDirectoryNames in interface Repository

Parameters:

id_directory - parent directory id

Returns:

array of child names

Throws:

org.pentaho.di.core.exception.KettleException

getJobId

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

Specified by:

getJobId in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getJobNames

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

Specified by:

getJobNames in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getJobNoteIDs

public org.pentaho.di.repository.ObjectId[] getJobNoteIDs(org.pentaho.di.repository.ObjectId id_job)
                                                   throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getJobsUsingDatabase

public String[] getJobsUsingDatabase(org.pentaho.di.repository.ObjectId id_database)
                              throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Get the repository version.

Specified by:

getJobsUsingDatabase in interface Repository

Returns:

The repository version as a string

Throws:

org.pentaho.di.core.exception.KettleException

getName

public String getName()

Specified by:

getName in interface Repository

Returns:

The name of the repository

getPartitionSchemaID

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

Specified by:

getPartitionSchemaID in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getPartitionSchemaIDs

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

Specified by:

getPartitionSchemaIDs in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getPartitionSchemaNames

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

Specified by:

getPartitionSchemaNames in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getRootDirectoryID

public org.pentaho.di.repository.ObjectId getRootDirectoryID()
                                                      throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getSlaveID

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

Specified by:

getSlaveID in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getSlaveIDs

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

Specified by:

getSlaveIDs in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getClusterSlaveIDs

public org.pentaho.di.repository.ObjectId[] getClusterSlaveIDs(org.pentaho.di.repository.ObjectId id_cluster_schema)
                                                        throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getSlaveNames

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

Specified by:

getSlaveNames in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getSlaveServers

public List<SlaveServer> getSlaveServers()
                                  throws org.pentaho.di.core.exception.KettleException

Specified by:

getSlaveServers in interface Repository

Returns:

a list of all the slave servers in the repository.

Throws:

org.pentaho.di.core.exception.KettleException

getStepAttributeBoolean

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

Specified by:

getStepAttributeBoolean in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getStepAttributeBoolean

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

Specified by:

getStepAttributeBoolean in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getStepAttributeBoolean

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

Specified by:

getStepAttributeBoolean in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getStepAttributeInteger

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

Specified by:

getStepAttributeInteger in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getStepAttributeInteger

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

Specified by:

getStepAttributeInteger in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getStepAttributeString

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

Specified by:

getStepAttributeString in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getStepAttributeString

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

Specified by:

getStepAttributeString in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getJobEntryAttributeBoolean

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

Specified by:

getJobEntryAttributeBoolean in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getJobEntryAttributeBoolean

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

Specified by:

getJobEntryAttributeBoolean in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getJobEntryAttributeBoolean

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

Specified by:

getJobEntryAttributeBoolean in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getJobEntryAttributeInteger

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

Specified by:

getJobEntryAttributeInteger in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getJobEntryAttributeInteger

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

Specified by:

getJobEntryAttributeInteger in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getJobEntryAttributeString

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

Specified by:

getJobEntryAttributeString in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getJobEntryAttributeString

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

Specified by:

getJobEntryAttributeString in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getSubConditionIDs

public org.pentaho.di.repository.ObjectId[] getSubConditionIDs(org.pentaho.di.repository.ObjectId id_condition)
                                                        throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getSubDirectoryIDs

public org.pentaho.di.repository.ObjectId[] getSubDirectoryIDs(org.pentaho.di.repository.ObjectId id_directory)
                                                        throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getTransNoteIDs

public org.pentaho.di.repository.ObjectId[] getTransNoteIDs(org.pentaho.di.repository.ObjectId id_transformation)
                                                     throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getTransformationClusterSchemaIDs

public org.pentaho.di.repository.ObjectId[] getTransformationClusterSchemaIDs(org.pentaho.di.repository.ObjectId id_transformation)
                                                                       throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getTransformationID

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

Specified by:

getTransformationID in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getTransformationNames

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

Specified by:

getTransformationNames in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getTransformationPartitionSchemaIDs

public org.pentaho.di.repository.ObjectId[] getTransformationPartitionSchemaIDs(org.pentaho.di.repository.ObjectId id_transformation)
                                                                         throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getTransformationsUsingCluster

public String[] getTransformationsUsingCluster(org.pentaho.di.repository.ObjectId id_cluster)
                                        throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getTransformationsUsingDatabase

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

Specified by:

getTransformationsUsingDatabase in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getTransformationsUsingPartitionSchema

public String[] getTransformationsUsingPartitionSchema(org.pentaho.di.repository.ObjectId id_partition_schema)
                                                throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getTransformationsUsingSlave

public String[] getTransformationsUsingSlave(org.pentaho.di.repository.ObjectId id_slave)
                                      throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getVersion

public String getVersion()

Description copied from interface: Repository

Get the repository version.

Specified by:

getVersion in interface Repository

Returns:

The repository version as a string

insertClusterSlave

public org.pentaho.di.repository.ObjectId insertClusterSlave(ClusterSchema clusterSchema,
                                                             SlaveServer slaveServer)
                                                      throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

insertJobEntryDatabase

public 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

Specified by:

insertJobEntryDatabase in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

insertJobNote

public void insertJobNote(org.pentaho.di.repository.ObjectId id_job,
                          org.pentaho.di.repository.ObjectId id_note)
                   throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

insertLogEntry

public org.pentaho.di.repository.ObjectId insertLogEntry(String description)
                                                  throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Insert an entry in the audit trail of the repository. This is an optional operation and depends on the capabilities of the underlying repository.

Specified by:

insertLogEntry in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

insertStepDatabase

public 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

Specified by:

insertStepDatabase in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

insertTransNote

public void insertTransNote(org.pentaho.di.repository.ObjectId id_transformation,
                            org.pentaho.di.repository.ObjectId id_note)
                     throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

insertTransStepCondition

public void insertTransStepCondition(org.pentaho.di.repository.ObjectId id_transformation,
                                     org.pentaho.di.repository.ObjectId id_step,
                                     org.pentaho.di.repository.ObjectId id_condition)
                              throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

insertTransformationCluster

public org.pentaho.di.repository.ObjectId insertTransformationCluster(org.pentaho.di.repository.ObjectId id_transformation,
                                                                      org.pentaho.di.repository.ObjectId id_cluster)
                                                               throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

insertTransformationPartitionSchema

public org.pentaho.di.repository.ObjectId insertTransformationPartitionSchema(org.pentaho.di.repository.ObjectId id_transformation,
                                                                              org.pentaho.di.repository.ObjectId id_partition_schema)
                                                                       throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

insertTransformationSlave

public org.pentaho.di.repository.ObjectId insertTransformationSlave(org.pentaho.di.repository.ObjectId id_transformation,
                                                                    org.pentaho.di.repository.ObjectId id_slave)
                                                             throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

loadClusterSchema

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

Specified by:

loadClusterSchema in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

loadCondition

public Condition loadCondition(org.pentaho.di.repository.ObjectId id_condition)
                        throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

loadConditionFromStepAttribute

public Condition loadConditionFromStepAttribute(org.pentaho.di.repository.ObjectId id_step,
                                                String code)
                                         throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Load a condition from the repository with the Object ID stored in a step attribute.

Specified by:

loadConditionFromStepAttribute in interface Repository

Returns:

Throws:

org.pentaho.di.core.exception.KettleException

loadNodeFromXML

public Node loadNodeFromXML(org.pentaho.di.repository.ObjectId id,
                            String tag)
                     throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

loadDatabaseMeta

public org.pentaho.di.core.database.DatabaseMeta loadDatabaseMeta(org.pentaho.di.repository.ObjectId id_database,
                                                                  String versionName)
                                                           throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Load the Database connection Metadata from the repository

Specified by:

loadDatabaseMeta in interface Repository

Parameters:

id_database - the id of the database connection to load

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

loadDatabaseMetaFromJobEntryAttribute

public 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

Description copied from interface: Repository

This method is introduced to avoid having to go over an integer/string/whatever in the interface and the job entry code.

Specified by:

loadDatabaseMetaFromJobEntryAttribute in interface Repository

Returns:

Throws:

org.pentaho.di.core.exception.KettleException

saveDatabaseMetaJobEntryAttribute

public 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

Description copied from interface: Repository

This method saves the object ID of the database object (if not null) in the job entry attributes

Specified by:

saveDatabaseMetaJobEntryAttribute in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

loadDatabaseMetaFromStepAttribute

public 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

Description copied from interface: Repository

This method is introduced to avoid having to go over an integer/string/whatever in the interface and the step code.

Specified by:

loadDatabaseMetaFromStepAttribute in interface Repository

Returns:

Throws:

org.pentaho.di.core.exception.KettleException

loadJob

public JobMeta loadJob(String jobname,
                       org.pentaho.di.repository.RepositoryDirectoryInterface repdir,
                       org.pentaho.di.core.ProgressMonitorListener monitor,
                       String versionName)
                throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Load a job from the repository

Specified by:

loadJob in interface Repository

Parameters:

jobname - the name

repdir - the directory

monitor - the progress monitor or null

versionName - the revision to load. Specify null to load the last version.

Throws:

org.pentaho.di.core.exception.KettleException

loadPartitionSchema

public PartitionSchema loadPartitionSchema(org.pentaho.di.repository.ObjectId id_partition_schema,
                                           String versionName)
                                    throws org.pentaho.di.core.exception.KettleException

Specified by:

loadPartitionSchema in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

loadRepositoryDirectoryTree

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

Specified by:

loadRepositoryDirectoryTree in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

loadRepositoryDirectoryTree

public org.pentaho.di.repository.RepositoryDirectoryInterface loadRepositoryDirectoryTree(org.pentaho.di.repository.RepositoryDirectoryInterface dir)
                                                                                   throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

findDirectory

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

Specified by:

findDirectory in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

findDirectory

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

Specified by:

findDirectory in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getTransformationObjects

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

Specified by:

getTransformationObjects in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getJobObjects

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

Specified by:

getJobObjects in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getNrSubDirectories

public int getNrSubDirectories(org.pentaho.di.repository.ObjectId id_directory)
                        throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

loadSlaveServer

public SlaveServer loadSlaveServer(org.pentaho.di.repository.ObjectId id_slave_server,
                                   String versionName)
                            throws org.pentaho.di.core.exception.KettleException

Specified by:

loadSlaveServer in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

loadTransformation

public TransMeta loadTransformation(String transname,
                                    org.pentaho.di.repository.RepositoryDirectoryInterface repdir,
                                    org.pentaho.di.core.ProgressMonitorListener monitor,
                                    boolean setInternalVariables,
                                    String versionName)
                             throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Load a transformation with a name from a folder in the repository

Specified by:

loadTransformation in interface Repository

Parameters:

transname - the name of the transformation to load

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

versionName - the revision to load. Specify null to load the last version.

Throws:

org.pentaho.di.core.exception.KettleException

loadValueMetaAndData

public org.pentaho.di.core.row.ValueMetaAndData loadValueMetaAndData(org.pentaho.di.repository.ObjectId id_value)
                                                              throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

moveJob

public void moveJob(String jobname,
                    org.pentaho.di.repository.ObjectId id_directory_from,
                    org.pentaho.di.repository.ObjectId id_directory_to)
             throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

moveTransformation

public void moveTransformation(String transname,
                               org.pentaho.di.repository.ObjectId id_directory_from,
                               org.pentaho.di.repository.ObjectId id_directory_to)
                        throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

readDatabases

public List<org.pentaho.di.core.database.DatabaseMeta> readDatabases()
                                                              throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Read all the databases defined in the repository

Specified by:

readDatabases in interface Repository

Returns:

a list of all the databases defined in the repository

Throws:

org.pentaho.di.core.exception.KettleException

clearSharedObjectCache

public void clearSharedObjectCache()

Clear the shared object cache, if applicable.

Specified by:

clearSharedObjectCache in interface Repository

readJobMetaSharedObjects

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

Specified by:

readJobMetaSharedObjects in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

readTransSharedObjects

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

Specified by:

readTransSharedObjects in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

renameJob

public org.pentaho.di.repository.ObjectId renameJob(org.pentaho.di.repository.ObjectId id_job,
                                                    org.pentaho.di.repository.RepositoryDirectoryInterface newDir,
                                                    String newName)
                                             throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Move / rename a job

Specified by:

renameJob in interface Repository

Parameters:

id_job - The ObjectId of the job to move

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

renameRepositoryDirectory

public 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

Description copied from interface: Repository

Move / rename a repository directory

Specified by:

renameRepositoryDirectory in interface Repository

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

renameTransformation

public org.pentaho.di.repository.ObjectId renameTransformation(org.pentaho.di.repository.ObjectId id_transformation,
                                                               org.pentaho.di.repository.RepositoryDirectoryInterface newDir,
                                                               String newName)
                                                        throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Move / rename a transformation

Specified by:

renameTransformation in interface Repository

Parameters:

id_transformation - The ObjectId of the transformation to move

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

saveCondition

public org.pentaho.di.repository.ObjectId saveCondition(Condition condition)
                                                 throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

saveCondition

public org.pentaho.di.repository.ObjectId saveCondition(Condition condition,
                                                        org.pentaho.di.repository.ObjectId id_condition_parent)
                                                 throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

saveConditionStepAttribute

public void saveConditionStepAttribute(org.pentaho.di.repository.ObjectId id_transformation,
                                       org.pentaho.di.repository.ObjectId id_step,
                                       String code,
                                       Condition condition)
                                throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

This method saves the object ID of the condition object (if not null) in the step attributes

Specified by:

saveConditionStepAttribute in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

saveDatabaseMetaJobEntryAttribute

public void saveDatabaseMetaJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job,
                                              org.pentaho.di.repository.ObjectId id_jobentry,
                                              String code,
                                              org.pentaho.di.core.database.DatabaseMeta database)
                                       throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

saveDatabaseMetaStepAttribute

public 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

Description copied from interface: Repository

This method saves the object ID of the database object (if not null) in the step attributes

Specified by:

saveDatabaseMetaStepAttribute in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

saveJobEntryAttribute

public 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

Specified by:

saveJobEntryAttribute in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

saveJobEntryAttribute

public 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

Specified by:

saveJobEntryAttribute in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

saveJobEntryAttribute

public 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

Specified by:

saveJobEntryAttribute in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

saveJobEntryAttribute

public 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

Specified by:

saveJobEntryAttribute in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

saveJobEntryAttribute

public 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

Specified by:

saveJobEntryAttribute in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

saveJobEntryAttribute

public 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

Specified by:

saveJobEntryAttribute in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

saveStepAttribute

public 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

Specified by:

saveStepAttribute in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

saveStepAttribute

public 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

Specified by:

saveStepAttribute in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

saveStepAttribute

public 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

Specified by:

saveStepAttribute in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

saveStepAttribute

public 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

Specified by:

saveStepAttribute in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

saveStepAttribute

public 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

Specified by:

saveStepAttribute in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

saveStepAttribute

public 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

Specified by:

saveStepAttribute in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

saveStepAttribute

public 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

Specified by:

saveStepAttribute in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

saveStepAttribute

public 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

Specified by:

saveStepAttribute in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

delUser

public void delUser(org.pentaho.di.repository.ObjectId id_user)
             throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getUserID

public org.pentaho.di.repository.ObjectId getUserID(String login)
                                             throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getUserIDs

public org.pentaho.di.repository.ObjectId[] getUserIDs()
                                                throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getUserInfo

public IUser getUserInfo()

Specified by:

getUserInfo in interface Repository

Returns:

the currently logged on user. (also available through the repository security provider)

getUserLogins

public String[] getUserLogins()
                       throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

loadUserInfo

public UserInfo loadUserInfo(String login)
                      throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

loadUserInfo

public UserInfo loadUserInfo(String login,
                             String password)
                      throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

renameUser

public void renameUser(org.pentaho.di.repository.ObjectId id_user,
                       String newname)
                throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

saveUserInfo

public void saveUserInfo(UserInfo userInfo)
                  throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

countNrJobEntryAttributes

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

Specified by:

countNrJobEntryAttributes in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

countNrStepAttributes

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

Specified by:

countNrStepAttributes in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getRepositoryMeta

public KettleFileRepositoryMeta getRepositoryMeta()

Specified by:

getRepositoryMeta in interface Repository

Returns:

the repositoryMeta

setRepositoryMeta

public void setRepositoryMeta(KettleFileRepositoryMeta repositoryMeta)

Parameters:

repositoryMeta - the repositoryMeta to set

undeleteObject

public void undeleteObject(org.pentaho.di.repository.RepositoryElementMetaInterface repositoryObject)
                    throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Removes he deleted flag from a repository element in the repository. If it wasn't deleted, it remains untouched.

Specified by:

undeleteObject in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException - get throws in case something goes horribly wrong.

getJobAndTransformationObjects

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

Description copied from interface: Repository

Gets all job and transformation objects in the given directory. (Combines Repository.getJobObjects(ObjectId, boolean) and Repository.getTransformationObjects(ObjectId, boolean) into one operation.

Specified by:

getJobAndTransformationObjects in interface Repository

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

getService

public IRepositoryService getService(Class<? extends IRepositoryService> clazz)
                              throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Retrieves a given repository service

Specified by:

getService in interface Repository

Returns:

repository service

Throws:

org.pentaho.di.core.exception.KettleException - in case something goes horribly wrong.

getServiceInterfaces

public List<Class<? extends IRepositoryService>> getServiceInterfaces()
                                                               throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Retrieves the current list of of IRepository Services.

Specified by:

getServiceInterfaces in interface Repository

Returns:

List of repository services

Throws:

org.pentaho.di.core.exception.KettleException - in case something goes horribly wrong.

hasService

public boolean hasService(Class<? extends IRepositoryService> clazz)
                   throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Checks whether a given repository service is available or not

Specified by:

hasService in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException - in case something goes horribly wrong.

getDefaultSaveDirectory

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

Specified by:

getDefaultSaveDirectory in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getUserHomeDirectory

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

Specified by:

getUserHomeDirectory in interface Repository

Throws:

org.pentaho.di.core.exception.KettleException

getObjectInformation

public RepositoryObject getObjectInformation(org.pentaho.di.repository.ObjectId objectId,
                                             org.pentaho.di.repository.RepositoryObjectType objectType)
                                      throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Get more information about a certain object ID in the form of the RepositoryObject

Specified by:

getObjectInformation in interface Repository

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.

loadJob

public JobMeta loadJob(org.pentaho.di.repository.ObjectId idJob,
                       String versionLabel)
                throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Load a job from the repository by id

Specified by:

loadJob in interface Repository

Parameters:

idJob - the id of the job

versionLabel - version to load. Specify null to load the last version.

Throws:

org.pentaho.di.core.exception.KettleException

loadTransformation

public TransMeta loadTransformation(org.pentaho.di.repository.ObjectId idTransformation,
                                    String versionLabel)
                             throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Load a transformation by id

Specified by:

loadTransformation in interface Repository

Parameters:

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

getConnectMessage

public String getConnectMessage()

Description copied from interface: Repository

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.

Specified by:

getConnectMessage in interface Repository

Returns:

message

getExporter

public IRepositoryExporter getExporter()

Specified by:

getExporter in interface Repository

Returns:

the exporter that will handle exports from this repository

getImporter

public IRepositoryImporter getImporter()

Specified by:

getImporter in interface Repository

Returns:

the importer that will handle imports into this repository