org.apache.flink.table.endpoint.hive.util

Class HiveJdbcParameterUtils

java.lang.Object

org.apache.flink.table.endpoint.hive.util.HiveJdbcParameterUtils

public class HiveJdbcParameterUtils
extends Object

Utils to normalize and validate hive jdbc conf.

Hive JDBC allows users to configure the session during the open session by setting values in its jdbc URL. The syntax is

     jdbc:hive2://host1:port1,host2:port2/dbName;initFile=file;sess_var_list?hive_conf_list#hive_var_list
 

For different parts in the URL, HiveConnection encodes different parts with different prefix and store them into the configuration.

Constructor Summary

Constructors

Constructor and Description
HiveJdbcParameterUtils()

Method Summary

Modifier and Type	Method and Description
static Optional<String>	getUsedDefaultDatabase(Map<String,String> parameters)
static void	setVariables(HiveConf hiveConf, Map<String,String> sessionConfigs, Map<String,String> parameters) Use the to set or according to what kinds of the parameter belongs.

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveJdbcParameterUtils

public HiveJdbcParameterUtils()

Method Detail

setVariables

public static void setVariables(HiveConf hiveConf,
                                Map<String,String> sessionConfigs,
                                Map<String,String> parameters)

Use the to set or according to what kinds of the parameter belongs.

getUsedDefaultDatabase

public static Optional<String> getUsedDefaultDatabase(Map<String,String> parameters)