org.apache.paimon.hive

Class PaimonStorageHandler

java.lang.Object

org.apache.paimon.hive.PaimonStorageHandler

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.hive.ql.metadata.HiveStorageHandler, org.apache.hadoop.hive.ql.metadata.HiveStoragePredicateHandler

Direct Known Subclasses:

TableStoreHiveStorageHandler

public class PaimonStorageHandler
extends Object
implements org.apache.hadoop.hive.ql.metadata.HiveStoragePredicateHandler, org.apache.hadoop.hive.ql.metadata.HiveStorageHandler

HiveStorageHandler for paimon. This is the entrance class of Hive API.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hive.ql.metadata.HiveStoragePredicateHandler

org.apache.hadoop.hive.ql.metadata.HiveStoragePredicateHandler.DecomposedPredicate

Field Summary

Fields

Modifier and Type	Field and Description
static String	PAIMON_TABLE_FIELDS

Constructor Summary

Constructors

Constructor and Description
PaimonStorageHandler()

Method Summary

Modifier and Type	Method and Description
void	configureInputJobCredentials(org.apache.hadoop.hive.ql.plan.TableDesc tableDesc, Map<String,String> map)
void	configureInputJobProperties(org.apache.hadoop.hive.ql.plan.TableDesc tableDesc, Map<String,String> 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> map)
void	configureTableJobProperties(org.apache.hadoop.hive.ql.plan.TableDesc tableDesc, Map<String,String> map)
org.apache.hadoop.hive.ql.metadata.HiveStoragePredicateHandler.DecomposedPredicate	decomposePredicate(org.apache.hadoop.mapred.JobConf jobConf, org.apache.hadoop.hive.serde2.Deserializer deserializer, org.apache.hadoop.hive.ql.plan.ExprNodeDesc predicate)
org.apache.hadoop.hive.ql.security.authorization.HiveAuthorizationProvider	getAuthorizationProvider()
org.apache.hadoop.conf.Configuration	getConf()
Class<? extends org.apache.hadoop.mapred.InputFormat>	getInputFormatClass()
org.apache.hadoop.hive.metastore.HiveMetaHook	getMetaHook()
Class<? extends org.apache.hadoop.mapred.OutputFormat>	getOutputFormatClass()
Class<? extends org.apache.hadoop.hive.serde2.AbstractSerDe>	getSerDeClass()
void	setConf(org.apache.hadoop.conf.Configuration configuration)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandler

getLockType, getStorageHandlerInfo

Field Detail

PAIMON_TABLE_FIELDS

public static final String PAIMON_TABLE_FIELDS

See Also:

Constant Field Values

Constructor Detail

PaimonStorageHandler

public PaimonStorageHandler()

Method Detail

getInputFormatClass

public Class<? extends org.apache.hadoop.mapred.InputFormat> getInputFormatClass()

Specified by:

getInputFormatClass in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandler

getOutputFormatClass

public Class<? extends org.apache.hadoop.mapred.OutputFormat> getOutputFormatClass()

Specified by:

getOutputFormatClass in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandler

getSerDeClass

public Class<? extends org.apache.hadoop.hive.serde2.AbstractSerDe> getSerDeClass()

Specified by:

getSerDeClass in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandler

getMetaHook

public org.apache.hadoop.hive.metastore.HiveMetaHook getMetaHook()

Specified by:

getMetaHook in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandler

getAuthorizationProvider

public org.apache.hadoop.hive.ql.security.authorization.HiveAuthorizationProvider getAuthorizationProvider()
                                                                                                    throws org.apache.hadoop.hive.ql.metadata.HiveException

Specified by:

getAuthorizationProvider in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandler

Throws:

org.apache.hadoop.hive.ql.metadata.HiveException

configureInputJobProperties

public void configureInputJobProperties(org.apache.hadoop.hive.ql.plan.TableDesc tableDesc,
                                        Map<String,String> map)

Specified by:

configureInputJobProperties in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandler

configureInputJobCredentials

public void configureInputJobCredentials(org.apache.hadoop.hive.ql.plan.TableDesc tableDesc,
                                         Map<String,String> map)

Specified by:

configureInputJobCredentials in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandler

configureOutputJobProperties

public void configureOutputJobProperties(org.apache.hadoop.hive.ql.plan.TableDesc tableDesc,
                                         Map<String,String> map)

Specified by:

configureOutputJobProperties in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandler

configureTableJobProperties

public void configureTableJobProperties(org.apache.hadoop.hive.ql.plan.TableDesc tableDesc,
                                        Map<String,String> map)

Specified by:

configureTableJobProperties in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandler

configureJobConf

public void configureJobConf(org.apache.hadoop.hive.ql.plan.TableDesc tableDesc,
                             org.apache.hadoop.mapred.JobConf jobConf)

Specified by:

configureJobConf in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandler

setConf

public void setConf(org.apache.hadoop.conf.Configuration configuration)

Specified by:

setConf in interface org.apache.hadoop.conf.Configurable

getConf

public org.apache.hadoop.conf.Configuration getConf()

Specified by:

getConf in interface org.apache.hadoop.conf.Configurable

decomposePredicate

public org.apache.hadoop.hive.ql.metadata.HiveStoragePredicateHandler.DecomposedPredicate decomposePredicate(org.apache.hadoop.mapred.JobConf jobConf,
                                                                                                             org.apache.hadoop.hive.serde2.Deserializer deserializer,
                                                                                                             org.apache.hadoop.hive.ql.plan.ExprNodeDesc predicate)

Specified by:

decomposePredicate in interface org.apache.hadoop.hive.ql.metadata.HiveStoragePredicateHandler