Package 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	Description
KettleDatabaseRepositoryPartitionSchemaDelegate(KettleDatabaseRepository repository)

Method Summary

Modifier and Type	Method	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)

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 org.pentaho.di.core.RowMetaAndData getPartitionSchema(org.pentaho.di.repository.ObjectId id_partition_schema)
                                                      throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getPartition

public org.pentaho.di.core.RowMetaAndData getPartition(org.pentaho.di.repository.ObjectId id_partition)
                                                throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getPartitionSchemaID

public org.pentaho.di.repository.ObjectId getPartitionSchemaID(String name)
                                                        throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

savePartitionSchema

public void savePartitionSchema(PartitionSchema partitionSchema)
                         throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

savePartitionSchema

public void savePartitionSchema(PartitionSchema partitionSchema,
                                org.pentaho.di.repository.ObjectId id_transformation,
                                boolean isUsedByTransformation)
                         throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

savePartitionSchema

public void savePartitionSchema(PartitionSchema partitionSchema,
                                org.pentaho.di.repository.ObjectId id_transformation,
                                boolean isUsedByTransformation,
                                boolean overwrite)
                         throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

loadPartitionSchema

public PartitionSchema loadPartitionSchema(org.pentaho.di.repository.ObjectId id_partition_schema)
                                    throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

insertPartitionSchema

public org.pentaho.di.repository.ObjectId insertPartitionSchema(PartitionSchema partitionSchema)
                                                         throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

updatePartitionSchema

public void updatePartitionSchema(PartitionSchema partitionSchema)
                           throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

insertPartition

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

Throws:

org.pentaho.di.core.exception.KettleException

delPartitionSchema

public void delPartitionSchema(org.pentaho.di.repository.ObjectId id_partition_schema)
                        throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException