org.pentaho.di.repository.kdr.delegates

Class KettleDatabaseRepositoryPartitionSchemaDelegate

java.lang.Object

org.pentaho.di.repository.kdr.delegates.KettleDatabaseRepositoryBaseDelegate

org.pentaho.di.repository.kdr.delegates.KettleDatabaseRepositoryPartitionSchemaDelegate

public class KettleDatabaseRepositoryPartitionSchemaDelegate
extends KettleDatabaseRepositoryBaseDelegate

Field Summary

Fields inherited from class org.pentaho.di.repository.kdr.delegates.KettleDatabaseRepositoryBaseDelegate

log, repository

Constructor Summary

Constructors

Constructor and Description
KettleDatabaseRepositoryPartitionSchemaDelegate(KettleDatabaseRepository repository)

Method Summary

Modifier and Type	Method and Description
void	delPartitionSchema(ObjectId id_partition_schema)
RowMetaAndData	getPartition(ObjectId id_partition)
RowMetaAndData	getPartitionSchema(ObjectId id_partition_schema)
ObjectId	getPartitionSchemaID(String name)
ObjectId	insertPartition(ObjectId id_partition_schema, String partition_id)
ObjectId	insertPartitionSchema(PartitionSchema partitionSchema)
PartitionSchema	loadPartitionSchema(ObjectId id_partition_schema)
void	savePartitionSchema(PartitionSchema partitionSchema)
void	savePartitionSchema(PartitionSchema partitionSchema, ObjectId id_transformation, boolean isUsedByTransformation)
void	savePartitionSchema(PartitionSchema partitionSchema, ObjectId id_transformation, boolean isUsedByTransformation, boolean overwrite)
void	updatePartitionSchema(PartitionSchema partitionSchema)

Methods inherited from class org.pentaho.di.repository.kdr.delegates.KettleDatabaseRepositoryBaseDelegate

quote, quoteTable

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KettleDatabaseRepositoryPartitionSchemaDelegate

public KettleDatabaseRepositoryPartitionSchemaDelegate(KettleDatabaseRepository repository)

Method Detail

getPartitionSchema

public RowMetaAndData getPartitionSchema(ObjectId id_partition_schema)
                                  throws KettleException

Throws:

KettleException

getPartition

public RowMetaAndData getPartition(ObjectId id_partition)
                            throws KettleException

Throws:

KettleException

getPartitionSchemaID

public ObjectId getPartitionSchemaID(String name)
                              throws KettleException

Throws:

KettleException

savePartitionSchema

public void savePartitionSchema(PartitionSchema partitionSchema)
                         throws KettleException

Throws:

KettleException

savePartitionSchema

public void savePartitionSchema(PartitionSchema partitionSchema,
                                ObjectId id_transformation,
                                boolean isUsedByTransformation)
                         throws KettleException

Throws:

KettleException

savePartitionSchema

public void savePartitionSchema(PartitionSchema partitionSchema,
                                ObjectId id_transformation,
                                boolean isUsedByTransformation,
                                boolean overwrite)
                         throws KettleException

Throws:

KettleException

loadPartitionSchema

public PartitionSchema loadPartitionSchema(ObjectId id_partition_schema)
                                    throws KettleException

Throws:

KettleException

insertPartitionSchema

public ObjectId insertPartitionSchema(PartitionSchema partitionSchema)
                               throws KettleException

Throws:

KettleException

updatePartitionSchema

public void updatePartitionSchema(PartitionSchema partitionSchema)
                           throws KettleException

Throws:

KettleException

insertPartition

public ObjectId insertPartition(ObjectId id_partition_schema,
                                String partition_id)
                         throws KettleException

Throws:

KettleException

delPartitionSchema

public void delPartitionSchema(ObjectId id_partition_schema)
                        throws KettleException

Throws:

KettleException