org.apache.hadoop.hive.ql.exec.spark

Class HiveSparkClientFactory

java.lang.Object

org.apache.hadoop.hive.ql.exec.spark.HiveSparkClientFactory

public class HiveSparkClientFactory
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOG
static String	SPARK_CLONE_CONFIGURATION

Constructor Summary

Constructors

Constructor and Description
HiveSparkClientFactory()

Method Summary

Modifier and Type	Method and Description
static HiveSparkClient	createHiveSparkClient(HiveConf hiveconf, String sessionId)
static Map<String,String>	initiateSparkConf(HiveConf hiveConf, String sessionId)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final transient org.slf4j.Logger LOG

SPARK_CLONE_CONFIGURATION

public static final String SPARK_CLONE_CONFIGURATION

See Also:

Constant Field Values

Constructor Detail

HiveSparkClientFactory

public HiveSparkClientFactory()

Method Detail

createHiveSparkClient

public static HiveSparkClient createHiveSparkClient(HiveConf hiveconf,
                                                    String sessionId)
                                             throws Exception

Throws:

Exception

initiateSparkConf

public static Map<String,String> initiateSparkConf(HiveConf hiveConf,
                                                   String sessionId)