org.apache.flink.table.planner.delegation.hive.copy

Class HiveSetProcessor

java.lang.Object

org.apache.flink.table.planner.delegation.hive.copy.HiveSetProcessor

public class HiveSetProcessor
extends Object

Counterpart of hive's SetProcessor.

Constructor Summary

Constructors

Constructor and Description
HiveSetProcessor()

Method Summary

Modifier and Type	Method and Description
static List<String>	dumpOptions(Properties p, HiveConf hiveConf, Map<String,String> hiveVariables, TableConfig tableConfig)
static String	getVariable(Map<String,String> flinkConf, HiveConf hiveConf, Map<String,String> hiveVariables, String varname)
static void	setVariable(HiveConf hiveConf, Map<String,String> hiveVariables, String varname, String varvalue) Set variable following Hive's implementation.
static boolean	startWithHiveSpecialVariablePrefix(String varname) check whether the variable's name is started with the special variable prefix that Hive reserves.

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveSetProcessor

public HiveSetProcessor()

Method Detail

setVariable

public static void setVariable(HiveConf hiveConf,
                               Map<String,String> hiveVariables,
                               String varname,
                               String varvalue)

Set variable following Hive's implementation.

startWithHiveSpecialVariablePrefix

public static boolean startWithHiveSpecialVariablePrefix(String varname)

check whether the variable's name is started with the special variable prefix that Hive reserves.

getVariable

public static String getVariable(Map<String,String> flinkConf,
                                 HiveConf hiveConf,
                                 Map<String,String> hiveVariables,
                                 String varname)

dumpOptions

public static List<String> dumpOptions(Properties p,
                                       HiveConf hiveConf,
                                       Map<String,String> hiveVariables,
                                       TableConfig tableConfig)