public class FosterStorageHandler extends DefaultStorageHandler
Modifier and Type | Field and Description |
---|---|
Configuration |
conf |
protected static java.lang.String |
DYNTEMP_DIR_NAME
The directory under which data is initially written for a partitioned table
|
protected static java.lang.String |
TEMP_DIR_NAME
The directory under which data is initially written for a non partitioned table
|
Constructor and Description |
---|
FosterStorageHandler(java.lang.Class<? extends InputFormat> ifClass,
java.lang.Class<? extends OutputFormat> ofClass,
java.lang.Class<? extends SerDe> serDeClass) |
FosterStorageHandler(java.lang.String ifName,
java.lang.String ofName,
java.lang.String serdeName) |
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 Configuration conf
protected static final java.lang.String DYNTEMP_DIR_NAME
protected static final java.lang.String TEMP_DIR_NAME
public FosterStorageHandler(java.lang.String ifName, java.lang.String ofName, java.lang.String serdeName) throws java.lang.ClassNotFoundException
java.lang.ClassNotFoundException
public FosterStorageHandler(java.lang.Class<? extends InputFormat> ifClass, java.lang.Class<? extends OutputFormat> ofClass, java.lang.Class<? extends SerDe> serDeClass)
public java.lang.Class<? extends InputFormat> getInputFormatClass()
getInputFormatClass
in interface HiveStorageHandler
getInputFormatClass
in class DefaultStorageHandler
InputFormat
public java.lang.Class<? extends OutputFormat> getOutputFormatClass()
getOutputFormatClass
in interface HiveStorageHandler
getOutputFormatClass
in class DefaultStorageHandler
OutputFormat
public java.lang.Class<? extends SerDe> getSerDeClass()
getSerDeClass
in interface HiveStorageHandler
getSerDeClass
in class DefaultStorageHandler
SerDe
public HiveMetaHook getMetaHook()
getMetaHook
in interface HiveStorageHandler
getMetaHook
in class DefaultStorageHandler
public void configureJobConf(TableDesc tableDesc, JobConf jobConf)
HiveStorageHandler
configureJobConf
in interface HiveStorageHandler
configureJobConf
in class DefaultStorageHandler
tableDesc
- descriptor for the table being accessedpublic void configureInputJobProperties(TableDesc tableDesc, java.util.Map<java.lang.String,java.lang.String> jobProperties)
HiveStorageHandler
configureInputJobProperties
in interface HiveStorageHandler
configureInputJobProperties
in class DefaultStorageHandler
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
configureOutputJobProperties
in class DefaultStorageHandler
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
configureTableJobProperties
in class DefaultStorageHandler
tableDesc
- descriptor for the table being accessedjobProperties
- receives properties copied or transformed
from the table propertiespublic Configuration getConf()
getConf
in class DefaultStorageHandler
public void setConf(Configuration conf)
setConf
in class DefaultStorageHandler
public HiveAuthorizationProvider getAuthorizationProvider() throws HiveException
HiveStorageHandler
getAuthorizationProvider
in interface HiveStorageHandler
getAuthorizationProvider
in class DefaultStorageHandler
HiveException
Copyright © 2012 The Apache Software Foundation