This project has retired. For details please refer to its Attic page.

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

HDFSStorage(String name)

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

Method Summary

void	commitAddPartition(StoragePartitionDesc addPartitionDesc) Called after successfully adding the partition
void	commitDropPartition(String storageTableName, List<String> partVals) Called after successfully droping the partition
void	preAddPartition(StoragePartitionDesc addPartitionDesc) Called before calling add partition
void	preDropPartition(String storageTableName, List<String> partVals) Called before calling drop partition
void	rollbackAddPartition(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, 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

preAddPartition

public void preAddPartition(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

commitAddPartition

public void commitAddPartition(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

rollbackAddPartition

public void rollbackAddPartition(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