Package 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

Field Summary

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

log, repository

Constructor Summary

Constructors

Constructor	Description
KettleDatabaseRepositoryClusterSchemaDelegate(KettleDatabaseRepository repository)

Method Summary

Modifier and Type	Method	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

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

Constructor Details

KettleDatabaseRepositoryClusterSchemaDelegate

public KettleDatabaseRepositoryClusterSchemaDelegate(KettleDatabaseRepository repository)

Method Details

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