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.

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(s)
void	commitDropPartition(String arg0, List<String> arg1) Called after successfully droping the partition
void	commitUpdatePartition(List<org.apache.hadoop.hive.ql.metadata.Partition> partitions) Called after successfully updating partition(s)
String	getDbUrl()
void	preAddPartitions(List<StoragePartitionDesc> arg0) Called before calling add partition(s)
void	preDropPartition(String arg0, List<String> arg1) 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> arg0) Called if add partition fails.
void	rollbackDropPartition(String arg0, List<String> arg1) 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

addPartition, 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, 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(s)

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(s)

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

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

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