public class DocumentDBStorageHandler
extends org.apache.hadoop.conf.Configured
implements org.apache.hadoop.hive.ql.metadata.HiveStorageHandler
| Constructor and Description |
|---|
DocumentDBStorageHandler() |
| Modifier and Type | Method and Description |
|---|---|
void |
configureInputJobProperties(org.apache.hadoop.hive.ql.plan.TableDesc tableDesc,
Map<String,String> jobProperties)
Set all DocumentDB input configuration properties to the jobProperties map.
|
void |
configureJobConf(org.apache.hadoop.hive.ql.plan.TableDesc tableDesc,
org.apache.hadoop.mapred.JobConf jobConf) |
void |
configureOutputJobProperties(org.apache.hadoop.hive.ql.plan.TableDesc tableDesc,
Map<String,String> jobProperties)
Set all DocumentDB output configuration properties to the jobProperties map.
|
void |
configureTableJobProperties(org.apache.hadoop.hive.ql.plan.TableDesc tableDesc,
Map<String,String> jobProperties)
Sets all the configuration properties for the connector in the properties map.
|
org.apache.hadoop.hive.ql.security.authorization.HiveAuthorizationProvider |
getAuthorizationProvider() |
Class<? extends org.apache.hadoop.mapred.InputFormat> |
getInputFormatClass()
Returns the DocumentDBInputFormat class.
|
org.apache.hadoop.hive.metastore.HiveMetaHook |
getMetaHook()
No metahook used.
|
Class<? extends org.apache.hadoop.mapred.OutputFormat> |
getOutputFormatClass()
Returns the DocumentDBOutputFormat class.
|
Class<? extends org.apache.hadoop.hive.serde2.SerDe> |
getSerDeClass()
Returns the DocumentDBSerde class.
|
public void configureTableJobProperties(org.apache.hadoop.hive.ql.plan.TableDesc tableDesc,
Map<String,String> jobProperties)
configureTableJobProperties in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandlerpublic Class<? extends org.apache.hadoop.mapred.InputFormat> getInputFormatClass()
getInputFormatClass in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandlerpublic org.apache.hadoop.hive.metastore.HiveMetaHook getMetaHook()
getMetaHook in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandlerpublic Class<? extends org.apache.hadoop.mapred.OutputFormat> getOutputFormatClass()
getOutputFormatClass in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandlerpublic void configureJobConf(org.apache.hadoop.hive.ql.plan.TableDesc tableDesc,
org.apache.hadoop.mapred.JobConf jobConf)
configureJobConf in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandlerpublic void configureInputJobProperties(org.apache.hadoop.hive.ql.plan.TableDesc tableDesc,
Map<String,String> jobProperties)
configureInputJobProperties in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandlerpublic void configureOutputJobProperties(org.apache.hadoop.hive.ql.plan.TableDesc tableDesc,
Map<String,String> jobProperties)
configureOutputJobProperties in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandlerpublic org.apache.hadoop.hive.ql.security.authorization.HiveAuthorizationProvider getAuthorizationProvider()
throws org.apache.hadoop.hive.ql.metadata.HiveException
getAuthorizationProvider in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandlerorg.apache.hadoop.hive.ql.metadata.HiveExceptionpublic Class<? extends org.apache.hadoop.hive.serde2.SerDe> getSerDeClass()
getSerDeClass in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandlerCopyright © 2015. All rights reserved.