| Package | Description | 
|---|---|
| org.pentaho.di.cluster | |
| org.pentaho.di.repository | 
 This package contains the required classes to handle the Kettle repository. 
 | 
| org.pentaho.di.repository.filerep | |
| org.pentaho.di.repository.kdr | |
| org.pentaho.di.repository.kdr.delegates | |
| org.pentaho.di.trans | 
 This package contains the classes needed to define and execute transformations. 
 | 
| org.pentaho.di.trans.step | 
| Modifier and Type | Method and Description | 
|---|---|
ClusterSchema | 
ClusterSchema.clone()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ClusterSchema.replaceMeta(ClusterSchema clusterSchema)  | 
| Modifier and Type | Method and Description | 
|---|---|
ClusterSchema | 
Repository.loadClusterSchema(org.pentaho.di.repository.ObjectId id_cluster_schema,
                 List<SlaveServer> slaveServers,
                 String versionLabel)  | 
| Modifier and Type | Method and Description | 
|---|---|
ClusterSchema | 
KettleFileRepository.loadClusterSchema(org.pentaho.di.repository.ObjectId id_cluster_schema,
                 List<SlaveServer> slaveServers,
                 String versionName)  | 
| Modifier and Type | Method and Description | 
|---|---|
org.pentaho.di.repository.ObjectId | 
KettleFileRepository.insertClusterSlave(ClusterSchema clusterSchema,
                  SlaveServer slaveServer)  | 
| Modifier and Type | Method and Description | 
|---|---|
ClusterSchema | 
KettleDatabaseRepository.loadClusterSchema(org.pentaho.di.repository.ObjectId idClusterSchema,
                 List<SlaveServer> slaveServers,
                 String versionLabel)  | 
| Modifier and Type | Method and Description | 
|---|---|
org.pentaho.di.repository.ObjectId | 
KettleDatabaseRepository.insertClusterSlave(ClusterSchema clusterSchema,
                  SlaveServer slaveServer)  | 
| Modifier and Type | Method and Description | 
|---|---|
ClusterSchema | 
KettleDatabaseRepositoryClusterSchemaDelegate.loadClusterSchema(org.pentaho.di.repository.ObjectId id_cluster_schema,
                 List<SlaveServer> slaveServers)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
KettleDatabaseRepositoryClusterSchemaDelegate.saveClusterSchema(ClusterSchema clusterSchema,
                 String versionComment)  | 
void | 
KettleDatabaseRepositoryClusterSchemaDelegate.saveClusterSchema(ClusterSchema clusterSchema,
                 String versionComment,
                 org.pentaho.di.repository.ObjectId id_transformation,
                 boolean isUsedByTransformation)  | 
void | 
KettleDatabaseRepositoryClusterSchemaDelegate.saveClusterSchema(ClusterSchema clusterSchema,
                 String versionComment,
                 org.pentaho.di.repository.ObjectId id_transformation,
                 boolean isUsedByTransformation,
                 boolean overwrite)  | 
void | 
KettleDatabaseRepositoryClusterSchemaDelegate.updateCluster(ClusterSchema clusterSchema)  | 
| Modifier and Type | Method and Description | 
|---|---|
ClusterSchema | 
TransMeta.findClusterSchema(String name)
Find a clustering schema using its name. 
 | 
ClusterSchema | 
TransMeta.findFirstUsedClusterSchema()
Finds the first used cluster schema. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
List<ClusterSchema> | 
TransMeta.getClusterSchemas()
Gets a list of the cluster schemas used by the transformation. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
TransMeta.addOrReplaceClusterSchema(ClusterSchema clusterSchema)
Add a new cluster schema to the transformation if that didn't exist yet. 
 | 
boolean | 
TransMeta.isUsingClusterSchema(ClusterSchema clusterSchema)
Checks if the transformation is using the specified cluster schema. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
TransMeta.setClusterSchemas(List<ClusterSchema> clusterSchemas)
Sets list of the cluster schemas used by the transformation. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
ClusterSchema | 
StepMeta.getClusterSchema()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
StepMeta.setClusterSchema(ClusterSchema clusterSchema)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
StepMeta.setClusterSchemaAfterLoading(List<ClusterSchema> clusterSchemas)
Resolves the name of the cluster loaded from XML/Repository to the correct clusterSchema object 
 |