public class KettleDatabaseRepositoryPartitionSchemaDelegate extends KettleDatabaseRepositoryBaseDelegate
Constructor and Description |
---|
KettleDatabaseRepositoryPartitionSchemaDelegate(KettleDatabaseRepository repository) |
Modifier and Type | Method and Description |
---|---|
void |
delPartitionSchema(org.pentaho.di.repository.ObjectId id_partition_schema) |
org.pentaho.di.core.RowMetaAndData |
getPartition(org.pentaho.di.repository.ObjectId id_partition) |
org.pentaho.di.core.RowMetaAndData |
getPartitionSchema(org.pentaho.di.repository.ObjectId id_partition_schema) |
org.pentaho.di.repository.ObjectId |
getPartitionSchemaID(String name) |
org.pentaho.di.repository.ObjectId |
insertPartition(org.pentaho.di.repository.ObjectId id_partition_schema,
String partition_id) |
org.pentaho.di.repository.ObjectId |
insertPartitionSchema(PartitionSchema partitionSchema) |
PartitionSchema |
loadPartitionSchema(org.pentaho.di.repository.ObjectId id_partition_schema) |
void |
savePartitionSchema(PartitionSchema partitionSchema) |
void |
savePartitionSchema(PartitionSchema partitionSchema,
org.pentaho.di.repository.ObjectId id_transformation,
boolean isUsedByTransformation) |
void |
savePartitionSchema(PartitionSchema partitionSchema,
org.pentaho.di.repository.ObjectId id_transformation,
boolean isUsedByTransformation,
boolean overwrite) |
void |
updatePartitionSchema(PartitionSchema partitionSchema) |
quote, quoteTable
public KettleDatabaseRepositoryPartitionSchemaDelegate(KettleDatabaseRepository repository)
public org.pentaho.di.core.RowMetaAndData getPartitionSchema(org.pentaho.di.repository.ObjectId id_partition_schema) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getPartition(org.pentaho.di.repository.ObjectId id_partition) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.repository.ObjectId getPartitionSchemaID(String name) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void savePartitionSchema(PartitionSchema partitionSchema) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void savePartitionSchema(PartitionSchema partitionSchema, org.pentaho.di.repository.ObjectId id_transformation, boolean isUsedByTransformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void savePartitionSchema(PartitionSchema partitionSchema, 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 PartitionSchema loadPartitionSchema(org.pentaho.di.repository.ObjectId id_partition_schema) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.repository.ObjectId insertPartitionSchema(PartitionSchema partitionSchema) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void updatePartitionSchema(PartitionSchema partitionSchema) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.repository.ObjectId insertPartition(org.pentaho.di.repository.ObjectId id_partition_schema, String partition_id) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delPartitionSchema(org.pentaho.di.repository.ObjectId id_partition_schema) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException