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

KettleDatabaseRepositoryClusterSchemaDelegate(KettleDatabaseRepository repository)

Method Summary

void	delClusterSchema(ObjectId id_cluster)
ObjectId	getClusterID(String name)
RowMetaAndData	getClusterSchema(ObjectId id_cluster_schema)
ClusterSchema	loadClusterSchema(ObjectId id_cluster_schema, List<SlaveServer> slaveServers)
void	renameClusterSchema(ObjectId id_cluster, String new_name)
void	saveClusterSchema(ClusterSchema clusterSchema, String versionComment)
void	saveClusterSchema(ClusterSchema clusterSchema, String versionComment, ObjectId id_transformation, boolean isUsedByTransformation)
void	saveClusterSchema(ClusterSchema clusterSchema, String versionComment, 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 RowMetaAndData getClusterSchema(ObjectId id_cluster_schema)
                                throws KettleException

Throws:

KettleException

getClusterID

public ObjectId getClusterID(String name)
                      throws KettleException

Throws:

KettleException

loadClusterSchema

public ClusterSchema loadClusterSchema(ObjectId id_cluster_schema,
                                       List<SlaveServer> slaveServers)
                                throws KettleException

Throws:

KettleException

saveClusterSchema

public void saveClusterSchema(ClusterSchema clusterSchema,
                              String versionComment)
                       throws KettleException

Throws:

KettleException

saveClusterSchema

public void saveClusterSchema(ClusterSchema clusterSchema,
                              String versionComment,
                              ObjectId id_transformation,
                              boolean isUsedByTransformation)
                       throws KettleException

Throws:

KettleException

saveClusterSchema

public void saveClusterSchema(ClusterSchema clusterSchema,
                              String versionComment,
                              ObjectId id_transformation,
                              boolean isUsedByTransformation,
                              boolean overwrite)
                       throws KettleException

Throws:

KettleException

updateCluster

public void updateCluster(ClusterSchema clusterSchema)
                   throws KettleException

Throws:

KettleException

delClusterSchema

public void delClusterSchema(ObjectId id_cluster)
                      throws KettleException

Throws:

KettleException

renameClusterSchema

public void renameClusterSchema(ObjectId id_cluster,
                                String new_name)
                         throws KettleException

Throws:

KettleException