public class SparkClientUtilities extends Object
Modifier and Type | Field and Description |
---|---|
static String |
HIVE_KRYO_REG_NAME |
protected static org.slf4j.Logger |
LOG |
Constructor and Description |
---|
SparkClientUtilities() |
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) |
protected static final transient org.slf4j.Logger LOG
public static final String HIVE_KRYO_REG_NAME
public static List<String> addToClassPath(Map<String,Long> newPaths, org.apache.hadoop.conf.Configuration conf, File localTmpDir) throws Exception
newPaths
- Map of classpath elements and corresponding timestampException
public static boolean isYarnMaster(String master)
public static boolean isLocalMaster(String master)
public static String findKryoRegistratorJar(HiveConf conf) throws FileNotFoundException
FileNotFoundException
public static void addJarToContextLoader(File jar) throws MalformedURLException
MalformedURLException
Copyright © 2022 The Apache Software Foundation. All rights reserved.