public class DefaultStorageHandler extends java.lang.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 |
configureInputJobProperties(TableDesc tableDesc,
java.util.Map<java.lang.String,java.lang.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,
JobConf jobConf)
Called just before submitting MapReduce job.
|
void |
configureOutputJobProperties(TableDesc tableDesc,
java.util.Map<java.lang.String,java.lang.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,
java.util.Map<java.lang.String,java.lang.String> jobProperties)
Deprecated use configureInputJobProperties/configureOutputJobProperties
methods instead.
|
HiveAuthorizationProvider |
getAuthorizationProvider()
Returns the implementation specific authorization provider
|
Configuration |
getConf() |
java.lang.Class<? extends InputFormat> |
getInputFormatClass() |
HiveMetaHook |
getMetaHook() |
java.lang.Class<? extends OutputFormat> |
getOutputFormatClass() |
java.lang.Class<? extends SerDe> |
getSerDeClass() |
void |
setConf(Configuration conf) |
public java.lang.Class<? extends InputFormat> getInputFormatClass()
getInputFormatClass
in interface HiveStorageHandler
InputFormat
public java.lang.Class<? extends OutputFormat> getOutputFormatClass()
getOutputFormatClass
in interface HiveStorageHandler
OutputFormat
public java.lang.Class<? extends SerDe> getSerDeClass()
getSerDeClass
in interface HiveStorageHandler
SerDe
public HiveMetaHook getMetaHook()
getMetaHook
in interface HiveStorageHandler
public HiveAuthorizationProvider getAuthorizationProvider() throws HiveException
HiveStorageHandler
getAuthorizationProvider
in interface HiveStorageHandler
HiveException
public void configureInputJobProperties(TableDesc tableDesc, java.util.Map<java.lang.String,java.lang.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, java.util.Map<java.lang.String,java.lang.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, java.util.Map<java.lang.String,java.lang.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, JobConf jobConf)
HiveStorageHandler
configureJobConf
in interface HiveStorageHandler
tableDesc
- descriptor for the table being accessedpublic Configuration getConf()
public void setConf(Configuration conf)
Copyright © 2012 The Apache Software Foundation