org.apache.lens.storage.db

Class DBStorage

java.lang.Object

org.apache.lens.cube.metadata.AbstractCubeTable

org.apache.lens.cube.metadata.Storage

org.apache.lens.storage.db.DBStorage

All Implemented Interfaces:

Named, PartitionMetahook

public class DBStorage
extends Storage

The Class DBStorage.

Nested Class Summary

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

Storage.LatestInfo, Storage.LatestPartColumnInfo

Field Summary

Fields

Modifier and Type	Field and Description
static String	DB_URL The Constant DB_URL.

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

LOG

Constructor Summary

Constructors

Constructor and Description
DBStorage(String name) Instantiates a new DB storage.
DBStorage(org.apache.hadoop.hive.ql.metadata.Table hiveTable) Instantiates a new DB storage.

Method Summary

Methods

Modifier and Type	Method and Description
void	commitAddPartitions(List<StoragePartitionDesc> arg0) Called after successfully adding the partition
void	commitDropPartition(String arg0, List<String> arg1) Called after successfully droping the partition
String	getDbUrl()
void	preAddPartitions(List<StoragePartitionDesc> arg0) Called before calling add partition
void	preDropPartition(String arg0, List<String> arg1) Called before calling drop partition
void	rollbackAddPartitions(List<StoragePartitionDesc> arg0) Called if add partition fails.
void	rollbackDropPartition(String arg0, List<String> arg1) 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

Field Detail

DB_URL

public static final String DB_URL

The Constant DB_URL.

See Also:

Constant Field Values

Constructor Detail

DBStorage

public DBStorage(String name)

Instantiates a new DB storage.

Parameters:

name - the name

DBStorage

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

Instantiates a new DB storage.

Parameters:

hiveTable - the hive table

Method Detail

getDbUrl

public String getDbUrl()

commitAddPartitions

public void commitAddPartitions(List<StoragePartitionDesc> arg0)
                         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

commitDropPartition

public void commitDropPartition(String arg0,
                       List<String> arg1)
                         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

preAddPartitions

public void preAddPartitions(List<StoragePartitionDesc> arg0)
                      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

preDropPartition

public void preDropPartition(String arg0,
                    List<String> arg1)
                      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

rollbackAddPartitions

public void rollbackAddPartitions(List<StoragePartitionDesc> arg0)
                           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

rollbackDropPartition

public void rollbackDropPartition(String arg0,
                         List<String> arg1)
                           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