org.apache.hive.spark.client.rpc

Class RpcConfiguration

java.lang.Object

org.apache.hive.spark.client.rpc.RpcConfiguration

@InterfaceAudience.Private
public final class RpcConfiguration
extends Object

Definitions of configuration keys and default values for the RPC layer.

Field Summary

Fields

Modifier and Type	Field and Description
static com.google.common.collect.ImmutableSet<String>	HIVE_SPARK_RSC_CONFIGS
static com.google.common.collect.ImmutableSet<String>	HIVE_SPARK_TIME_CONFIGS
static String	RPC_SASL_OPT_PREFIX Prefix for other SASL options.

Constructor Summary

Constructors

Constructor and Description
RpcConfiguration(Map<String,String> config)

Method Summary

Modifier and Type	Method and Description
int	getRpcThreadCount()
static String	getValue(HiveConf conf, String key) Utility method for a given RpcConfiguration key, to convert value to millisecond if it is a time value, and return as string in either case.

Methods inherited from class java.lang.Object

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

Field Detail

HIVE_SPARK_RSC_CONFIGS

public static final com.google.common.collect.ImmutableSet<String> HIVE_SPARK_RSC_CONFIGS

HIVE_SPARK_TIME_CONFIGS

public static final com.google.common.collect.ImmutableSet<String> HIVE_SPARK_TIME_CONFIGS

RPC_SASL_OPT_PREFIX

public static final String RPC_SASL_OPT_PREFIX

Prefix for other SASL options.

See Also:

Constant Field Values

Constructor Detail

RpcConfiguration

public RpcConfiguration(Map<String,String> config)

Method Detail

getRpcThreadCount

public int getRpcThreadCount()

getValue

public static String getValue(HiveConf conf,
                              String key)

Utility method for a given RpcConfiguration key, to convert value to millisecond if it is a time value, and return as string in either case.

Parameters:

conf - hive configuration

key - Rpc configuration to lookup (hive.spark.*)

Returns:

string form of the value