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
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)
|
KettleDatabaseRepositoryClusterSchemaDelegate
public KettleDatabaseRepositoryClusterSchemaDelegate(KettleDatabaseRepository repository)
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