public class KettleDatabaseRepositoryClusterSchemaDelegate extends KettleDatabaseRepositoryBaseDelegate
Constructor and Description |
---|
KettleDatabaseRepositoryClusterSchemaDelegate(KettleDatabaseRepository repository) |
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) |
quote, quoteTable
public KettleDatabaseRepositoryClusterSchemaDelegate(KettleDatabaseRepository repository)
public org.pentaho.di.core.RowMetaAndData getClusterSchema(org.pentaho.di.repository.ObjectId id_cluster_schema) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.repository.ObjectId getClusterID(String name) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public ClusterSchema loadClusterSchema(org.pentaho.di.repository.ObjectId id_cluster_schema, List<SlaveServer> slaveServers) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void saveClusterSchema(ClusterSchema clusterSchema, String versionComment) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void saveClusterSchema(ClusterSchema clusterSchema, String versionComment, org.pentaho.di.repository.ObjectId id_transformation, boolean isUsedByTransformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
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
org.pentaho.di.core.exception.KettleException
public void updateCluster(ClusterSchema clusterSchema) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delClusterSchema(org.pentaho.di.repository.ObjectId id_cluster) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void renameClusterSchema(org.pentaho.di.repository.ObjectId id_cluster, String new_name) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException