Package | Description |
---|---|
org.pentaho.di.partition | |
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 |
---|---|
void |
PartitionSchema.replaceMeta(PartitionSchema partitionSchema) |
Modifier and Type | Method and Description |
---|---|
PartitionSchema |
Repository.loadPartitionSchema(org.pentaho.di.repository.ObjectId id_partition_schema,
String versionLabel) |
Modifier and Type | Method and Description |
---|---|
PartitionSchema |
KettleFileRepository.loadPartitionSchema(org.pentaho.di.repository.ObjectId id_partition_schema,
String versionName) |
Modifier and Type | Method and Description |
---|---|
PartitionSchema |
KettleDatabaseRepository.loadPartitionSchema(org.pentaho.di.repository.ObjectId id_partition_schema,
String versionName) |
Modifier and Type | Method and Description |
---|---|
PartitionSchema |
KettleDatabaseRepositoryPartitionSchemaDelegate.loadPartitionSchema(org.pentaho.di.repository.ObjectId id_partition_schema) |
Modifier and Type | Method and Description |
---|---|
org.pentaho.di.repository.ObjectId |
KettleDatabaseRepositoryPartitionSchemaDelegate.insertPartitionSchema(PartitionSchema partitionSchema) |
void |
KettleDatabaseRepositoryPartitionSchemaDelegate.savePartitionSchema(PartitionSchema partitionSchema) |
void |
KettleDatabaseRepositoryPartitionSchemaDelegate.savePartitionSchema(PartitionSchema partitionSchema,
org.pentaho.di.repository.ObjectId id_transformation,
boolean isUsedByTransformation) |
void |
KettleDatabaseRepositoryPartitionSchemaDelegate.savePartitionSchema(PartitionSchema partitionSchema,
org.pentaho.di.repository.ObjectId id_transformation,
boolean isUsedByTransformation,
boolean overwrite) |
void |
KettleDatabaseRepositoryPartitionSchemaDelegate.updatePartitionSchema(PartitionSchema partitionSchema) |
Modifier and Type | Method and Description |
---|---|
StepMeta |
KettleDatabaseRepositoryStepDelegate.loadStepMeta(org.pentaho.di.repository.ObjectId stepId,
List<org.pentaho.di.core.database.DatabaseMeta> databases,
List<PartitionSchema> partitionSchemas)
Create a new step by loading the metadata from the specified repository.
|
Modifier and Type | Method and Description |
---|---|
PartitionSchema |
TransMeta.findPartitionSchema(String name)
Find a partition schema using its name.
|
Modifier and Type | Method and Description |
---|---|
List<PartitionSchema> |
SlaveStepCopyPartitionDistribution.getOriginalPartitionSchemas() |
List<PartitionSchema> |
TransMeta.getPartitionSchemas()
Gets a list of partition schemas for this transformation.
|
Modifier and Type | Method and Description |
---|---|
void |
TransMeta.addOrReplacePartitionSchema(PartitionSchema partitionSchema)
Add a new partition schema to the transformation if that didn't exist yet.
|
boolean |
TransMeta.isUsingPartitionSchema(PartitionSchema partitionSchema)
Checks if the transformation is using the specified partition schema.
|
Modifier and Type | Method and Description |
---|---|
void |
SlaveStepCopyPartitionDistribution.setOriginalPartitionSchemas(List<PartitionSchema> originalPartitionSchemas) |
void |
TransMeta.setPartitionSchemas(List<PartitionSchema> partitionSchemas)
Sets the list of partition schemas for this transformation.
|
Modifier and Type | Method and Description |
---|---|
PartitionSchema |
StepPartitioningMeta.getPartitionSchema() |
Modifier and Type | Method and Description |
---|---|
void |
StepPartitioningMeta.setPartitionSchema(PartitionSchema partitionSchema) |
Modifier and Type | Method and Description |
---|---|
void |
StepPartitioningMeta.setPartitionSchemaAfterLoading(List<PartitionSchema> partitionSchemas)
Set the partitioning schema after loading from XML or repository
|
Constructor and Description |
---|
StepPartitioningMeta(String method,
PartitionSchema partitionSchema) |