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.HiveStorageHandler
public Class<? extends org.apache.hadoop.mapred.InputFormat> getInputFormatClass()
getInputFormatClass
in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandler
public org.apache.hadoop.hive.metastore.HiveMetaHook getMetaHook()
getMetaHook
in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandler
public Class<? extends org.apache.hadoop.mapred.OutputFormat> getOutputFormatClass()
getOutputFormatClass
in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandler
public 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.HiveStorageHandler
public void configureInputJobProperties(org.apache.hadoop.hive.ql.plan.TableDesc tableDesc, Map<String,String> jobProperties)
configureInputJobProperties
in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandler
public void configureOutputJobProperties(org.apache.hadoop.hive.ql.plan.TableDesc tableDesc, Map<String,String> jobProperties)
configureOutputJobProperties
in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandler
public 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.HiveStorageHandler
org.apache.hadoop.hive.ql.metadata.HiveException
public Class<? extends org.apache.hadoop.hive.serde2.SerDe> getSerDeClass()
getSerDeClass
in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandler
Copyright © 2015. All rights reserved.