public class HDFSStorage extends Storage
Storage.LatestInfo, Storage.LatestPartColumnInfo
Constructor and Description |
---|
HDFSStorage(String name) |
HDFSStorage(org.apache.hadoop.hive.ql.metadata.Table hiveTable) |
Modifier and Type | Method and Description |
---|---|
void |
commitAddPartitions(List<StoragePartitionDesc> addPartitionDesc)
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> addPartitionDesc)
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> addPartitionDesc)
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)
|
addPartition, addPartitions, dropPartition, getPrefix, getPrefix, getStorages, getStorageTable, getTableType, updatePartition, updatePartitions
addProperties, alterWeight, equals, getAllFieldNames, getColumns, getName, getProperties, getWeight, hashCode, removeProperty, toString, weight
public HDFSStorage(String name)
public HDFSStorage(org.apache.hadoop.hive.ql.metadata.Table hiveTable)
public void preAddPartitions(List<StoragePartitionDesc> addPartitionDesc) throws org.apache.hadoop.hive.ql.metadata.HiveException
PartitionMetahook
org.apache.hadoop.hive.ql.metadata.HiveException
public void commitAddPartitions(List<StoragePartitionDesc> addPartitionDesc) throws org.apache.hadoop.hive.ql.metadata.HiveException
PartitionMetahook
org.apache.hadoop.hive.ql.metadata.HiveException
public void rollbackAddPartitions(List<StoragePartitionDesc> addPartitionDesc) throws org.apache.hadoop.hive.ql.metadata.HiveException
PartitionMetahook
org.apache.hadoop.hive.ql.metadata.HiveException
public void preUpdatePartition(List<org.apache.hadoop.hive.ql.metadata.Partition> partitions) throws org.apache.hadoop.hive.ql.metadata.HiveException
PartitionMetahook
org.apache.hadoop.hive.ql.metadata.HiveException
public void commitUpdatePartition(List<org.apache.hadoop.hive.ql.metadata.Partition> partitions) throws org.apache.hadoop.hive.ql.metadata.HiveException
PartitionMetahook
org.apache.hadoop.hive.ql.metadata.HiveException
public void rollbackUpdatePartition(List<org.apache.hadoop.hive.ql.metadata.Partition> partitions) throws org.apache.hadoop.hive.ql.metadata.HiveException
PartitionMetahook
org.apache.hadoop.hive.ql.metadata.HiveException
public void preDropPartition(String storageTableName, List<String> partVals) throws org.apache.hadoop.hive.ql.metadata.HiveException
PartitionMetahook
org.apache.hadoop.hive.ql.metadata.HiveException
public void commitDropPartition(String storageTableName, List<String> partVals) throws org.apache.hadoop.hive.ql.metadata.HiveException
PartitionMetahook
org.apache.hadoop.hive.ql.metadata.HiveException
public void rollbackDropPartition(String storageTableName, List<String> partVals) throws org.apache.hadoop.hive.ql.metadata.HiveException
PartitionMetahook
org.apache.hadoop.hive.ql.metadata.HiveException
Copyright © 2014–2016 Apache Software Foundation. All rights reserved.