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.Modifier and Type | Field and Description |
---|---|
static String |
PAIMON_TABLE_FIELDS |
Constructor and Description |
---|
PaimonStorageHandler() |
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) |
public static final String PAIMON_TABLE_FIELDS
public Class<? extends org.apache.hadoop.mapred.InputFormat> getInputFormatClass()
getInputFormatClass
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 Class<? extends org.apache.hadoop.hive.serde2.AbstractSerDe> getSerDeClass()
getSerDeClass
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 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 void configureInputJobProperties(org.apache.hadoop.hive.ql.plan.TableDesc tableDesc, Map<String,String> map)
configureInputJobProperties
in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandler
public void configureInputJobCredentials(org.apache.hadoop.hive.ql.plan.TableDesc tableDesc, Map<String,String> map)
configureInputJobCredentials
in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandler
public void configureOutputJobProperties(org.apache.hadoop.hive.ql.plan.TableDesc tableDesc, Map<String,String> map)
configureOutputJobProperties
in interface org.apache.hadoop.hive.ql.metadata.HiveStorageHandler
public void configureTableJobProperties(org.apache.hadoop.hive.ql.plan.TableDesc tableDesc, Map<String,String> map)
configureTableJobProperties
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 setConf(org.apache.hadoop.conf.Configuration configuration)
setConf
in interface org.apache.hadoop.conf.Configurable
public org.apache.hadoop.conf.Configuration getConf()
getConf
in interface org.apache.hadoop.conf.Configurable
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)
decomposePredicate
in interface org.apache.hadoop.hive.ql.metadata.HiveStoragePredicateHandler
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.