org.apache.hive.spark.client

Class SparkClientUtilities

java.lang.Object

org.apache.hive.spark.client.SparkClientUtilities

public class SparkClientUtilities
extends Object

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
SparkClientUtilities()

Method Summary

Modifier and Type	Method and Description
static void	addJarToContextLoader(File jar)
static List<String>	addToClassPath(Map<String,Long> newPaths, org.apache.hadoop.conf.Configuration conf, File localTmpDir) Add new elements to the classpath.
static String	findKryoRegistratorJar(HiveConf conf)
static String	getDeployModeFromMaster(String master)
static boolean	isLocalMaster(String master)
static boolean	isYarnClientMode(String master, String deployMode)
static boolean	isYarnClusterMode(String master, String deployMode)
static boolean	isYarnMaster(String master)

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

HIVE_KRYO_REG_NAME

public static final String HIVE_KRYO_REG_NAME

See Also:

Constant Field Values

Constructor Detail

SparkClientUtilities

public SparkClientUtilities()

Method Detail

addToClassPath

public static List<String> addToClassPath(Map<String,Long> newPaths,
                                          org.apache.hadoop.conf.Configuration conf,
                                          File localTmpDir)
                                   throws Exception

Add new elements to the classpath.

Parameters:

newPaths - Map of classpath elements and corresponding timestamp

Returns:

locally accessible files corresponding to the newPaths

Throws:

Exception

isYarnClusterMode

public static boolean isYarnClusterMode(String master,
                                        String deployMode)

isYarnClientMode

public static boolean isYarnClientMode(String master,
                                       String deployMode)

isYarnMaster

public static boolean isYarnMaster(String master)

isLocalMaster

public static boolean isLocalMaster(String master)

getDeployModeFromMaster

public static String getDeployModeFromMaster(String master)

findKryoRegistratorJar

public static String findKryoRegistratorJar(HiveConf conf)
                                     throws FileNotFoundException

Throws:

FileNotFoundException

addJarToContextLoader

public static void addJarToContextLoader(File jar)
                                  throws MalformedURLException

Throws:

MalformedURLException