public class MesosTaskManagerParameters extends Object
ContaineredTaskManagerParameters
.Modifier and Type | Class and Description |
---|---|
static class |
MesosTaskManagerParameters.ContainerType |
Modifier and Type | Field and Description |
---|---|
static String |
MESOS_RESOURCEMANAGER_TASKS_CONTAINER_TYPE_DOCKER
Value for
MESOS_RESOURCEMANAGER_TASKS_CONTAINER_TYPE setting. |
static String |
MESOS_RESOURCEMANAGER_TASKS_CONTAINER_TYPE_MESOS
Value for
MESOS_RESOURCEMANAGER_TASKS_CONTAINER_TYPE setting. |
static ConfigOption<String> |
MESOS_RM_CONTAINER_IMAGE_NAME |
static ConfigOption<String> |
MESOS_RM_CONTAINER_TYPE |
static ConfigOption<Double> |
MESOS_RM_TASKS_CPUS |
static ConfigOption<Integer> |
MESOS_RM_TASKS_MEMORY_MB |
static ConfigOption<Integer> |
MESOS_RM_TASKS_SLOTS |
Constructor and Description |
---|
MesosTaskManagerParameters(double cpus,
MesosTaskManagerParameters.ContainerType containerType,
scala.Option<String> containerImageName,
ContaineredTaskManagerParameters containeredParameters) |
Modifier and Type | Method and Description |
---|---|
ContaineredTaskManagerParameters |
containeredParameters()
Get the common containered parameters.
|
scala.Option<String> |
containerImageName()
Get the container image name.
|
MesosTaskManagerParameters.ContainerType |
containerType()
Get the container type (Mesos or Docker).
|
double |
cpus()
Get the CPU units to use for the TaskManager process.
|
static MesosTaskManagerParameters |
create(Configuration flinkConfig)
Create the Mesos TaskManager parameters.
|
String |
toString() |
public static final ConfigOption<Integer> MESOS_RM_TASKS_SLOTS
public static final ConfigOption<Integer> MESOS_RM_TASKS_MEMORY_MB
public static final ConfigOption<Double> MESOS_RM_TASKS_CPUS
public static final ConfigOption<String> MESOS_RM_CONTAINER_TYPE
public static final ConfigOption<String> MESOS_RM_CONTAINER_IMAGE_NAME
public static final String MESOS_RESOURCEMANAGER_TASKS_CONTAINER_TYPE_MESOS
MESOS_RESOURCEMANAGER_TASKS_CONTAINER_TYPE
setting. Tells to use the Mesos containerizer.public static final String MESOS_RESOURCEMANAGER_TASKS_CONTAINER_TYPE_DOCKER
MESOS_RESOURCEMANAGER_TASKS_CONTAINER_TYPE
setting. Tells to use the Docker containerizer.public MesosTaskManagerParameters(double cpus, MesosTaskManagerParameters.ContainerType containerType, scala.Option<String> containerImageName, ContaineredTaskManagerParameters containeredParameters)
public double cpus()
public MesosTaskManagerParameters.ContainerType containerType()
public scala.Option<String> containerImageName()
public ContaineredTaskManagerParameters containeredParameters()
public static MesosTaskManagerParameters create(Configuration flinkConfig)
flinkConfig
- the TM configuration.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.