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

java.lang.Object
  extended by org.pentaho.di.repository.kdr.delegates.KettleDatabaseRepositoryBaseDelegate
      extended by 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