org.apache.lens.storage.db

Class DBStorageHandler

java.lang.Object

org.apache.lens.storage.db.DBStorageHandler

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.hive.metastore.HiveMetaHook, org.apache.hadoop.hive.ql.metadata.HiveStorageHandler

public class DBStorageHandler
extends Object
implements org.apache.hadoop.hive.ql.metadata.HiveStorageHandler, org.apache.hadoop.hive.metastore.HiveMetaHook

The Class DBStorageHandler.

Constructor Summary

Constructors

Constructor and Description
DBStorageHandler()

Method Summary

Modifier and Type	Method and Description
void	commitCreateTable(org.apache.hadoop.hive.metastore.api.Table arg0)
void	commitDropTable(org.apache.hadoop.hive.metastore.api.Table arg0, boolean arg1)
void	configureInputJobProperties(org.apache.hadoop.hive.ql.plan.TableDesc arg0, Map<String,String> arg1)
void	configureJobConf(org.apache.hadoop.hive.ql.plan.TableDesc arg0, org.apache.hadoop.mapred.JobConf arg1)
void	configureOutputJobProperties(org.apache.hadoop.hive.ql.plan.TableDesc arg0, Map<String,String> arg1)
void	configureTableJobProperties(org.apache.hadoop.hive.ql.plan.TableDesc arg0, Map<String,String> arg1)
org.apache.hadoop.hive.ql.security.authorization.HiveAuthorizationProvider	getAuthorizationProvider()
org.apache.hadoop.conf.Configuration	getConf()
Class<? extends org.apache.hadoop.mapred.InputFormat>	getInputFormatClass()
org.apache.hadoop.hive.metastore.HiveMetaHook	getMetaHook()
Class<? extends org.apache.hadoop.mapred.OutputFormat>	getOutputFormatClass()
Class<? extends org.apache.hadoop.hive.serde2.SerDe>	getSerDeClass()
void	preCreateTable(org.apache.hadoop.hive.metastore.api.Table arg0)
void	preDropTable(org.apache.hadoop.hive.metastore.api.Table arg0)
void	rollbackCreateTable(org.apache.hadoop.hive.metastore.api.Table arg0)
void	rollbackDropTable(org.apache.hadoop.hive.metastore.api.Table arg0)
void	setConf(org.apache.hadoop.conf.Configuration conf)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DBStorageHandler

public DBStorageHandler()

Method Detail

configureInputJobProperties

public void configureInputJobProperties(org.apache.hadoop.hive.ql.plan.TableDesc arg0,
                                        Map<String,String> arg1)

Specified by:

configureInputJobProperties in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandler

configureJobConf

public void configureJobConf(org.apache.hadoop.hive.ql.plan.TableDesc arg0,
                             org.apache.hadoop.mapred.JobConf arg1)

Specified by:

configureJobConf in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandler

configureOutputJobProperties

public void configureOutputJobProperties(org.apache.hadoop.hive.ql.plan.TableDesc arg0,
                                         Map<String,String> arg1)

Specified by:

configureOutputJobProperties in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandler

configureTableJobProperties

public void configureTableJobProperties(org.apache.hadoop.hive.ql.plan.TableDesc arg0,
                                        Map<String,String> arg1)

Specified by:

configureTableJobProperties in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandler

getAuthorizationProvider

public org.apache.hadoop.hive.ql.security.authorization.HiveAuthorizationProvider getAuthorizationProvider()
                                                                                                    throws org.apache.hadoop.hive.ql.metadata.HiveException

Specified by:

getAuthorizationProvider in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandler

Throws:

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

getInputFormatClass

public Class<? extends org.apache.hadoop.mapred.InputFormat> getInputFormatClass()

Specified by:

getInputFormatClass in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandler

getMetaHook

public org.apache.hadoop.hive.metastore.HiveMetaHook getMetaHook()

Specified by:

getMetaHook in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandler

getOutputFormatClass

public Class<? extends org.apache.hadoop.mapred.OutputFormat> getOutputFormatClass()

Specified by:

getOutputFormatClass in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandler

getSerDeClass

public Class<? extends org.apache.hadoop.hive.serde2.SerDe> getSerDeClass()

Specified by:

getSerDeClass in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandler

setConf

public void setConf(org.apache.hadoop.conf.Configuration conf)

Specified by:

setConf in interface org.apache.hadoop.conf.Configurable

getConf

public org.apache.hadoop.conf.Configuration getConf()

Specified by:

getConf in interface org.apache.hadoop.conf.Configurable

commitCreateTable

public void commitCreateTable(org.apache.hadoop.hive.metastore.api.Table arg0)
                       throws org.apache.hadoop.hive.metastore.api.MetaException

Specified by:

commitCreateTable in interface org.apache.hadoop.hive.metastore.HiveMetaHook

Throws:

org.apache.hadoop.hive.metastore.api.MetaException

commitDropTable

public void commitDropTable(org.apache.hadoop.hive.metastore.api.Table arg0,
                            boolean arg1)
                     throws org.apache.hadoop.hive.metastore.api.MetaException

Specified by:

commitDropTable in interface org.apache.hadoop.hive.metastore.HiveMetaHook

Throws:

org.apache.hadoop.hive.metastore.api.MetaException

preCreateTable

public void preCreateTable(org.apache.hadoop.hive.metastore.api.Table arg0)
                    throws org.apache.hadoop.hive.metastore.api.MetaException

Specified by:

preCreateTable in interface org.apache.hadoop.hive.metastore.HiveMetaHook

Throws:

org.apache.hadoop.hive.metastore.api.MetaException

preDropTable

public void preDropTable(org.apache.hadoop.hive.metastore.api.Table arg0)
                  throws org.apache.hadoop.hive.metastore.api.MetaException

Specified by:

preDropTable in interface org.apache.hadoop.hive.metastore.HiveMetaHook

Throws:

org.apache.hadoop.hive.metastore.api.MetaException

rollbackCreateTable

public void rollbackCreateTable(org.apache.hadoop.hive.metastore.api.Table arg0)
                         throws org.apache.hadoop.hive.metastore.api.MetaException

Specified by:

rollbackCreateTable in interface org.apache.hadoop.hive.metastore.HiveMetaHook

Throws:

org.apache.hadoop.hive.metastore.api.MetaException

rollbackDropTable

public void rollbackDropTable(org.apache.hadoop.hive.metastore.api.Table arg0)
                       throws org.apache.hadoop.hive.metastore.api.MetaException

Specified by:

rollbackDropTable in interface org.apache.hadoop.hive.metastore.HiveMetaHook

Throws:

org.apache.hadoop.hive.metastore.api.MetaException