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
|