public interface PartitionMetahook
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)
|
void preAddPartitions(List<StoragePartitionDesc> storagePartitionDesc) throws org.apache.hadoop.hive.ql.metadata.HiveException
storagePartitionDesc
- org.apache.hadoop.hive.ql.metadata.HiveException
void commitAddPartitions(List<StoragePartitionDesc> storagePartitionDesc) throws org.apache.hadoop.hive.ql.metadata.HiveException
storagePartitionDesc
- org.apache.hadoop.hive.ql.metadata.HiveException
void rollbackAddPartitions(List<StoragePartitionDesc> storagePartitionDesc) throws org.apache.hadoop.hive.ql.metadata.HiveException
storagePartitionDesc
- org.apache.hadoop.hive.ql.metadata.HiveException
void preUpdatePartition(List<org.apache.hadoop.hive.ql.metadata.Partition> partitions) throws org.apache.hadoop.hive.ql.metadata.HiveException
partitions
- org.apache.hadoop.hive.ql.metadata.HiveException
void commitUpdatePartition(List<org.apache.hadoop.hive.ql.metadata.Partition> partitions) throws org.apache.hadoop.hive.ql.metadata.HiveException
partitions
- org.apache.hadoop.hive.ql.metadata.HiveException
void rollbackUpdatePartition(List<org.apache.hadoop.hive.ql.metadata.Partition> partitions) throws org.apache.hadoop.hive.ql.metadata.HiveException
partitions
- org.apache.hadoop.hive.ql.metadata.HiveException
void preDropPartition(String storageTableName, List<String> partVals) throws org.apache.hadoop.hive.ql.metadata.HiveException
storageTableName
- partVals
- org.apache.hadoop.hive.ql.metadata.HiveException
void commitDropPartition(String storageTableName, List<String> partVals) throws org.apache.hadoop.hive.ql.metadata.HiveException
storageTableName
- partVals
- org.apache.hadoop.hive.ql.metadata.HiveException
Copyright © 2014–2016 Apache Software Foundation. All rights reserved.