org.apache.lens.cube.metadata

Class HDFSStorage

java.lang.Object

org.apache.lens.cube.metadata.AbstractCubeTable

org.apache.lens.cube.metadata.Storage

org.apache.lens.cube.metadata.HDFSStorage

All Implemented Interfaces:

Named, PartitionMetahook

public class HDFSStorage
extends Storage

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.lens.cube.metadata.Storage

Storage.LatestInfo, Storage.LatestPartColumnInfo

Constructor Summary

Constructors

Constructor and Description
HDFSStorage(String name)
HDFSStorage(org.apache.hadoop.hive.ql.metadata.Table hiveTable)

Method Summary

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)

Methods inherited from class org.apache.lens.cube.metadata.Storage

addPartitions, dropPartition, getPrefix, getPrefix, getStorages, getStorageTable, getTableType, updatePartition, updatePartitions

Methods inherited from class org.apache.lens.cube.metadata.AbstractCubeTable

addProperties, alterWeight, equals, getAllFieldNames, getColumns, getName, getProperties, getWeight, hashCode, now, removeProperty, toString, weight

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

HDFSStorage

public HDFSStorage(String name)

HDFSStorage

public HDFSStorage(org.apache.hadoop.hive.ql.metadata.Table hiveTable)

Method Detail

preAddPartitions

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

Description copied from interface: PartitionMetahook

Called before calling add partition(s)

Throws:

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

commitAddPartitions

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

Description copied from interface: PartitionMetahook

Called after successfully adding the partition(s)

Throws:

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

rollbackAddPartitions

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

Description copied from interface: PartitionMetahook

Called if add partition fails.

Throws:

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

preUpdatePartition

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

Description copied from interface: PartitionMetahook

Called before calling update partition(s)

Throws:

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

commitUpdatePartition

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

Description copied from interface: PartitionMetahook

Called after successfully updating partition(s)

Throws:

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

rollbackUpdatePartition

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

Description copied from interface: PartitionMetahook

Called after failed updating partition(s)

Throws:

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

preDropPartition

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

Description copied from interface: PartitionMetahook

Called before calling drop partition

Throws:

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

commitDropPartition

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

Description copied from interface: PartitionMetahook

Called after successfully droping the partition

Throws:

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

rollbackDropPartition

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

Description copied from interface: PartitionMetahook

Called if drop partition fails.

Throws:

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