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

Field Summary

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

LOG

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
void	commitAddPartitions(List<StoragePartitionDesc> addPartitionDesc) Called after successfully adding the partition
void	commitDropPartition(String storageTableName, List<String> partVals) Called after successfully droping the partition
void	preAddPartitions(List<StoragePartitionDesc> addPartitionDesc) Called before calling add partition
void	preDropPartition(String storageTableName, List<String> partVals) Called before calling drop partition
void	rollbackAddPartitions(List<StoragePartitionDesc> addPartitionDesc) Called if add partition fails.
void	rollbackDropPartition(String storageTableName, List<String> partVals) Called if drop partition fails.

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

addPartition, addPartitions, dropPartition, getPrefix, getPrefix, getStorages, getStorageTable, getTableType

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

addProperties, alterWeight, equals, getAllFieldNames, getColumns, getName, getProperties, getWeight, hashCode, 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

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

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

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