public class DefaultStorageHandler extends Object implements HiveStorageHandler
HiveStorageHandler
which supplies the standard defaults for all options. This can be useful
either as the base class for custom storage handlers, or as a mock in tests
(providing something which appears to be a non-native table with respect to
metadata even though its behavior is otherwise identical to a native table).Constructor and Description |
---|
DefaultStorageHandler() |
Modifier and Type | Method and Description |
---|---|
void |
configureInputJobCredentials(TableDesc tableDesc,
Map<String,String> secrets)
This method is called to allow the StorageHandlers the chance to
populate secret keys into the job's credentials.
|
void |
configureInputJobProperties(TableDesc tableDesc,
Map<String,String> jobProperties)
This method is called to allow the StorageHandlers the chance
to populate the JobContext.getConfiguration() with properties that
maybe be needed by the handler's bundled artifacts (ie InputFormat, SerDe, etc).
|
void |
configureJobConf(TableDesc tableDesc,
org.apache.hadoop.mapred.JobConf jobConf)
Called just before submitting MapReduce job.
|
void |
configureOutputJobProperties(TableDesc tableDesc,
Map<String,String> jobProperties)
This method is called to allow the StorageHandlers the chance
to populate the JobContext.getConfiguration() with properties that
maybe be needed by the handler's bundled artifacts (ie InputFormat, SerDe, etc).
|
void |
configureTableJobProperties(TableDesc tableDesc,
Map<String,String> jobProperties)
Deprecated use configureInputJobProperties/configureOutputJobProperties
methods instead.
|
HiveAuthorizationProvider |
getAuthorizationProvider()
Returns the implementation specific authorization provider
|
org.apache.hadoop.conf.Configuration |
getConf() |
Class<? extends org.apache.hadoop.mapred.InputFormat> |
getInputFormatClass() |
HiveMetaHook |
getMetaHook() |
Class<? extends org.apache.hadoop.mapred.OutputFormat> |
getOutputFormatClass() |
Class<? extends AbstractSerDe> |
getSerDeClass() |
void |
setConf(org.apache.hadoop.conf.Configuration conf) |
String |
toString() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getLockType, getStorageHandlerInfo
public Class<? extends org.apache.hadoop.mapred.InputFormat> getInputFormatClass()
getInputFormatClass
in interface HiveStorageHandler
InputFormat
public Class<? extends org.apache.hadoop.mapred.OutputFormat> getOutputFormatClass()
getOutputFormatClass
in interface HiveStorageHandler
OutputFormat
public Class<? extends AbstractSerDe> getSerDeClass()
getSerDeClass
in interface HiveStorageHandler
AbstractSerDe
public HiveMetaHook getMetaHook()
getMetaHook
in interface HiveStorageHandler
public HiveAuthorizationProvider getAuthorizationProvider() throws HiveException
HiveStorageHandler
getAuthorizationProvider
in interface HiveStorageHandler
HiveException
public void configureInputJobProperties(TableDesc tableDesc, Map<String,String> jobProperties)
HiveStorageHandler
configureInputJobProperties
in interface HiveStorageHandler
tableDesc
- descriptor for the table being accessedjobProperties
- receives properties copied or transformed
from the table propertiespublic void configureOutputJobProperties(TableDesc tableDesc, Map<String,String> jobProperties)
HiveStorageHandler
configureOutputJobProperties
in interface HiveStorageHandler
tableDesc
- descriptor for the table being accessedjobProperties
- receives properties copied or transformed
from the table propertiespublic void configureTableJobProperties(TableDesc tableDesc, Map<String,String> jobProperties)
HiveStorageHandler
configureTableJobProperties
in interface HiveStorageHandler
tableDesc
- descriptor for the table being accessedjobProperties
- receives properties copied or transformed
from the table propertiespublic void configureJobConf(TableDesc tableDesc, org.apache.hadoop.mapred.JobConf jobConf)
HiveStorageHandler
configureJobConf
in interface HiveStorageHandler
tableDesc
- descriptor for the table being accessedjobConf
- jobConf for MapReduce jobpublic void configureInputJobCredentials(TableDesc tableDesc, Map<String,String> secrets)
HiveStorageHandler
configureInputJobCredentials
in interface HiveStorageHandler
public org.apache.hadoop.conf.Configuration getConf()
getConf
in interface org.apache.hadoop.conf.Configurable
public void setConf(org.apache.hadoop.conf.Configuration conf)
setConf
in interface org.apache.hadoop.conf.Configurable
Copyright © 2019 The Apache Software Foundation. All rights reserved.