org.pentaho.di.repository.kdr.delegates

Class KettleDatabaseRepositoryClusterSchemaDelegate

java.lang.Object

org.pentaho.di.repository.kdr.delegates.KettleDatabaseRepositoryBaseDelegate

org.pentaho.di.repository.kdr.delegates.KettleDatabaseRepositoryClusterSchemaDelegate

public class KettleDatabaseRepositoryClusterSchemaDelegate
extends KettleDatabaseRepositoryBaseDelegate

Constructor Summary

Constructors

Constructor and Description
KettleDatabaseRepositoryClusterSchemaDelegate(KettleDatabaseRepository repository)

Method Summary

Modifier and Type	Method and Description
void	delClusterSchema(org.pentaho.di.repository.ObjectId id_cluster)
org.pentaho.di.repository.ObjectId	getClusterID(String name)
org.pentaho.di.core.RowMetaAndData	getClusterSchema(org.pentaho.di.repository.ObjectId id_cluster_schema)
ClusterSchema	loadClusterSchema(org.pentaho.di.repository.ObjectId id_cluster_schema, List<SlaveServer> slaveServers)
void	renameClusterSchema(org.pentaho.di.repository.ObjectId id_cluster, String new_name)
void	saveClusterSchema(ClusterSchema clusterSchema, String versionComment)
void	saveClusterSchema(ClusterSchema clusterSchema, String versionComment, org.pentaho.di.repository.ObjectId id_transformation, boolean isUsedByTransformation)
void	saveClusterSchema(ClusterSchema clusterSchema, String versionComment, org.pentaho.di.repository.ObjectId id_transformation, boolean isUsedByTransformation, boolean overwrite)
void	updateCluster(ClusterSchema clusterSchema)

Methods inherited from class org.pentaho.di.repository.kdr.delegates.KettleDatabaseRepositoryBaseDelegate

quote, quoteTable

Methods inherited from class java.lang.Object

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

Constructor Detail

KettleDatabaseRepositoryClusterSchemaDelegate

public KettleDatabaseRepositoryClusterSchemaDelegate(KettleDatabaseRepository repository)

Method Detail

getClusterSchema

public org.pentaho.di.core.RowMetaAndData getClusterSchema(org.pentaho.di.repository.ObjectId id_cluster_schema)
                                                    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

Throws:

org.pentaho.di.core.exception.KettleException

loadClusterSchema

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

Throws:

org.pentaho.di.core.exception.KettleException

saveClusterSchema

public void saveClusterSchema(ClusterSchema clusterSchema,
                              String versionComment)
                       throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

saveClusterSchema

public void saveClusterSchema(ClusterSchema clusterSchema,
                              String versionComment,
                              org.pentaho.di.repository.ObjectId id_transformation,
                              boolean isUsedByTransformation)
                       throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

saveClusterSchema

public void saveClusterSchema(ClusterSchema clusterSchema,
                              String versionComment,
                              org.pentaho.di.repository.ObjectId id_transformation,
                              boolean isUsedByTransformation,
                              boolean overwrite)
                       throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

updateCluster

public void updateCluster(ClusterSchema clusterSchema)
                   throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

delClusterSchema

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

Throws:

org.pentaho.di.core.exception.KettleException

renameClusterSchema

public void renameClusterSchema(org.pentaho.di.repository.ObjectId id_cluster,
                                String new_name)
                         throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException