Package | Description |
---|---|
org.apache.flink.kubernetes.kubeclient.parameters | |
org.apache.flink.mesos.runtime.clusterframework | |
org.apache.flink.runtime.clusterframework |
This package contains the cluster resource management functionality.
|
Modifier and Type | Method and Description |
---|---|
ContaineredTaskManagerParameters |
KubernetesTaskManagerParameters.getContaineredTaskManagerParameters() |
Constructor and Description |
---|
KubernetesTaskManagerParameters(Configuration flinkConfig,
String podName,
String dynamicProperties,
ContaineredTaskManagerParameters containeredTaskManagerParameters,
Map<String,Long> taskManagerExternalResources) |
Modifier and Type | Method and Description |
---|---|
ContaineredTaskManagerParameters |
MesosTaskManagerParameters.containeredParameters()
Get the common containered parameters.
|
Constructor and Description |
---|
MesosTaskManagerParameters(int gpus,
int disk,
int network,
MesosTaskManagerParameters.ContainerType containerType,
scala.Option<String> containerImageName,
ContaineredTaskManagerParameters containeredParameters,
List<org.apache.mesos.Protos.Volume> containerVolumes,
List<org.apache.mesos.Protos.Parameter> dockerParameters,
boolean dockerForcePullImage,
List<com.netflix.fenzo.ConstraintEvaluator> constraints,
String command,
scala.Option<String> bootstrapCommand,
scala.Option<String> taskManagerHostname,
List<String> uris) |
Modifier and Type | Method and Description |
---|---|
static ContaineredTaskManagerParameters |
ContaineredTaskManagerParameters.create(Configuration config,
TaskExecutorProcessSpec taskExecutorProcessSpec)
Computes the parameters to be used to start a TaskManager Java process.
|
Modifier and Type | Method and Description |
---|---|
static String |
BootstrapTools.getTaskManagerShellCommand(Configuration flinkConfig,
ContaineredTaskManagerParameters tmParams,
String configDirectory,
String logDirectory,
boolean hasLogback,
boolean hasLog4j,
boolean hasKrb5,
Class<?> mainClass,
String mainArgs)
Generates the shell command to start a task manager.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.