public class MesosSchedulerBackendUtil
extends java.lang.Object
Constructor and Description |
---|
MesosSchedulerBackendUtil() |
Modifier and Type | Method and Description |
---|---|
static void |
addDockerInfo(org.apache.mesos.Protos.ContainerInfo.Builder container,
java.lang.String image,
scala.Option<scala.collection.immutable.List<org.apache.mesos.Protos.Volume>> volumes,
scala.Option<org.apache.mesos.Protos.ContainerInfo.DockerInfo.Network> network,
scala.Option<scala.collection.immutable.List<org.apache.mesos.Protos.ContainerInfo.DockerInfo.PortMapping>> portmaps)
Construct a DockerInfo structure and insert it into a ContainerInfo
|
protected static void |
initializeLogIfNecessary(boolean isInterpreter) |
protected static boolean |
isTraceEnabled() |
protected static org.slf4j.Logger |
log() |
protected static void |
logDebug(scala.Function0<java.lang.String> msg) |
protected static void |
logDebug(scala.Function0<java.lang.String> msg,
java.lang.Throwable throwable) |
protected static void |
logError(scala.Function0<java.lang.String> msg) |
protected static void |
logError(scala.Function0<java.lang.String> msg,
java.lang.Throwable throwable) |
protected static void |
logInfo(scala.Function0<java.lang.String> msg) |
protected static void |
logInfo(scala.Function0<java.lang.String> msg,
java.lang.Throwable throwable) |
protected static java.lang.String |
logName() |
protected static void |
logTrace(scala.Function0<java.lang.String> msg) |
protected static void |
logTrace(scala.Function0<java.lang.String> msg,
java.lang.Throwable throwable) |
protected static void |
logWarning(scala.Function0<java.lang.String> msg) |
protected static void |
logWarning(scala.Function0<java.lang.String> msg,
java.lang.Throwable throwable) |
static scala.collection.immutable.List<org.apache.mesos.Protos.ContainerInfo.DockerInfo.PortMapping> |
parsePortMappingsSpec(java.lang.String portmaps)
Parse a comma-delimited list of port mapping specs, each of which
takes the form host_port:container_port[:udp|:tcp]
|
static scala.collection.immutable.List<org.apache.mesos.Protos.Volume> |
parseVolumesSpec(java.lang.String volumes)
Parse a comma-delimited list of volume specs, each of which
takes the form [host-dir:]container-dir[:rw|:ro].
|
static void |
setupContainerBuilderDockerInfo(java.lang.String imageName,
SparkConf conf,
org.apache.mesos.Protos.ContainerInfo.Builder builder)
Setup a docker containerizer
|
public static scala.collection.immutable.List<org.apache.mesos.Protos.Volume> parseVolumesSpec(java.lang.String volumes)
volumes
- (undocumented)public static scala.collection.immutable.List<org.apache.mesos.Protos.ContainerInfo.DockerInfo.PortMapping> parsePortMappingsSpec(java.lang.String portmaps)
Note: the docker form is [ip:]host_port:container_port, but the DockerInfo message has no field for 'ip', and instead has a 'protocol' field. Docker itself only appears to support TCP, so this alternative form anticipates the expansion of the docker form to allow for a protocol and leaves open the chance for mesos to begin to accept an 'ip' field
portmaps
- (undocumented)public static void addDockerInfo(org.apache.mesos.Protos.ContainerInfo.Builder container, java.lang.String image, scala.Option<scala.collection.immutable.List<org.apache.mesos.Protos.Volume>> volumes, scala.Option<org.apache.mesos.Protos.ContainerInfo.DockerInfo.Network> network, scala.Option<scala.collection.immutable.List<org.apache.mesos.Protos.ContainerInfo.DockerInfo.PortMapping>> portmaps)
container
- (undocumented)image
- (undocumented)volumes
- (undocumented)network
- (undocumented)portmaps
- (undocumented)public static void setupContainerBuilderDockerInfo(java.lang.String imageName, SparkConf conf, org.apache.mesos.Protos.ContainerInfo.Builder builder)
imageName
- (undocumented)conf
- (undocumented)builder
- (undocumented)protected static java.lang.String logName()
protected static org.slf4j.Logger log()
protected static void logInfo(scala.Function0<java.lang.String> msg)
protected static void logDebug(scala.Function0<java.lang.String> msg)
protected static void logTrace(scala.Function0<java.lang.String> msg)
protected static void logWarning(scala.Function0<java.lang.String> msg)
protected static void logError(scala.Function0<java.lang.String> msg)
protected static void logInfo(scala.Function0<java.lang.String> msg, java.lang.Throwable throwable)
protected static void logDebug(scala.Function0<java.lang.String> msg, java.lang.Throwable throwable)
protected static void logTrace(scala.Function0<java.lang.String> msg, java.lang.Throwable throwable)
protected static void logWarning(scala.Function0<java.lang.String> msg, java.lang.Throwable throwable)
protected static void logError(scala.Function0<java.lang.String> msg, java.lang.Throwable throwable)
protected static boolean isTraceEnabled()
protected static void initializeLogIfNecessary(boolean isInterpreter)