public class SparkClientUtilities extends Object
Modifier and Type | Field and Description |
---|---|
protected static org.slf4j.Logger |
LOG |
Constructor and Description |
---|
SparkClientUtilities() |
Modifier and Type | Method and Description |
---|---|
static List<String> |
addToClassPath(Map<String,Long> newPaths,
org.apache.hadoop.conf.Configuration conf,
File localTmpDir)
Add new elements to the classpath by creating a child ClassLoader containing both old and new paths.
|
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) |
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)
Copyright © 2021 The Apache Software Foundation. All rights reserved.