org.apache.hive.spark.client

Class SparkClientFactory

java.lang.Object

org.apache.hive.spark.client.SparkClientFactory

@InterfaceAudience.Private
public final class SparkClientFactory
extends Object

Factory for SparkClient instances.

Constructor Summary

Constructors

Constructor and Description
SparkClientFactory()

Method Summary

Methods

Modifier and Type	Method and Description
static SparkClient	createClient(Map<String,String> sparkConf, HiveConf hiveConf) Instantiates a new Spark client.
static void	initialize(Map<String,String> conf) Initializes the SparkClient library.
static void	stop() Stops the SparkClient library.

Methods inherited from class java.lang.Object

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

Constructor Detail

SparkClientFactory

public SparkClientFactory()

Method Detail

initialize

public static void initialize(Map<String,String> conf)
                       throws IOException

Initializes the SparkClient library. Must be called before creating client instances.

Parameters:

conf - Map containing configuration parameters for the client library.

Throws:

IOException

stop

public static void stop()

Stops the SparkClient library.

createClient

public static SparkClient createClient(Map<String,String> sparkConf,
                       HiveConf hiveConf)
                                throws IOException,
                                       org.apache.spark.SparkException

Instantiates a new Spark client.

Parameters:

sparkConf - Configuration for the remote Spark application, contains spark.* properties.

hiveConf - Configuration for Hive, contains hive.* properties.

Throws:

IOException

org.apache.spark.SparkException