org.apache.lens.cube.metadata

Interface PartitionMetahook

All Known Implementing Classes:

DBStorage, HDFSStorage, Storage

public interface PartitionMetahook

Method Summary

Modifier and Type	Method and Description
void	commitAddPartitions(List<StoragePartitionDesc> storagePartitionDesc) Called after successfully adding the partition(s)
void	commitDropPartition(String storageTableName, List<String> partVals) Called after successfully droping the partition
void	commitUpdatePartition(List<org.apache.hadoop.hive.ql.metadata.Partition> partitions) Called after successfully updating partition(s)
void	preAddPartitions(List<StoragePartitionDesc> storagePartitionDesc) Called before calling add partition(s)
void	preDropPartition(String storageTableName, List<String> partVals) Called before calling drop partition
void	preUpdatePartition(List<org.apache.hadoop.hive.ql.metadata.Partition> partitions) Called before calling update partition(s)
void	rollbackAddPartitions(List<StoragePartitionDesc> storagePartitionDesc) Called if add partition fails.
void	rollbackDropPartition(String storageTableName, List<String> partVals) Called if drop partition fails.
void	rollbackUpdatePartition(List<org.apache.hadoop.hive.ql.metadata.Partition> partitions) Called after failed updating partition(s)

Method Detail

preAddPartitions

void preAddPartitions(List<StoragePartitionDesc> storagePartitionDesc)
               throws org.apache.hadoop.hive.ql.metadata.HiveException

Called before calling add partition(s)

Parameters:

storagePartitionDesc -

Throws:

org.apache.hadoop.hive.ql.metadata.HiveException

commitAddPartitions

void commitAddPartitions(List<StoragePartitionDesc> storagePartitionDesc)
                  throws org.apache.hadoop.hive.ql.metadata.HiveException

Called after successfully adding the partition(s)

Parameters:

storagePartitionDesc -

Throws:

org.apache.hadoop.hive.ql.metadata.HiveException

rollbackAddPartitions

void rollbackAddPartitions(List<StoragePartitionDesc> storagePartitionDesc)
                    throws org.apache.hadoop.hive.ql.metadata.HiveException

Called if add partition fails.

Parameters:

storagePartitionDesc -

Throws:

org.apache.hadoop.hive.ql.metadata.HiveException

preUpdatePartition

void preUpdatePartition(List<org.apache.hadoop.hive.ql.metadata.Partition> partitions)
                 throws org.apache.hadoop.hive.ql.metadata.HiveException

Called before calling update partition(s)

Parameters:

partitions -

Throws:

org.apache.hadoop.hive.ql.metadata.HiveException

commitUpdatePartition

void commitUpdatePartition(List<org.apache.hadoop.hive.ql.metadata.Partition> partitions)
                    throws org.apache.hadoop.hive.ql.metadata.HiveException

Called after successfully updating partition(s)

Parameters:

partitions -

Throws:

org.apache.hadoop.hive.ql.metadata.HiveException

rollbackUpdatePartition

void rollbackUpdatePartition(List<org.apache.hadoop.hive.ql.metadata.Partition> partitions)
                      throws org.apache.hadoop.hive.ql.metadata.HiveException

Called after failed updating partition(s)

Parameters:

partitions -

Throws:

org.apache.hadoop.hive.ql.metadata.HiveException

preDropPartition

void preDropPartition(String storageTableName,
                      List<String> partVals)
               throws org.apache.hadoop.hive.ql.metadata.HiveException

Called before calling drop partition

Parameters:

storageTableName -

partVals -

Throws:

org.apache.hadoop.hive.ql.metadata.HiveException

commitDropPartition

void commitDropPartition(String storageTableName,
                         List<String> partVals)
                  throws org.apache.hadoop.hive.ql.metadata.HiveException

Called after successfully droping the partition

Parameters:

storageTableName -

partVals -

Throws:

org.apache.hadoop.hive.ql.metadata.HiveException

rollbackDropPartition

void rollbackDropPartition(String storageTableName,
                           List<String> partVals)
                    throws org.apache.hadoop.hive.ql.metadata.HiveException

Called if drop partition fails.

Parameters:

storageTableName -

partVals -

Throws:

org.apache.hadoop.hive.ql.metadata.HiveException