public class KubernetesTaskManagerParameters extends AbstractKubernetesParameters
Modifier and Type | Field and Description |
---|---|
static String |
TASK_MANAGER_MAIN_CONTAINER_NAME |
flinkConfig
Constructor and Description |
---|
KubernetesTaskManagerParameters(Configuration flinkConfig,
String podName,
String dynamicProperties,
ContaineredTaskManagerParameters containeredTaskManagerParameters,
Map<String,Long> taskManagerExternalResources) |
Modifier and Type | Method and Description |
---|---|
Map<String,String> |
getAnnotations()
A map of user-specified annotations that are set to the JobManager and TaskManager pods.
|
ContaineredTaskManagerParameters |
getContaineredTaskManagerParameters() |
String |
getDynamicProperties() |
Map<String,String> |
getEnvironments()
A collection of customized environments that are attached to the JobManager and TaskManager
Container(s).
|
Map<String,String> |
getLabels()
A collection of labels that are attached to the JobManager and TaskManager Pod(s).
|
Map<String,String> |
getNodeSelector()
A collection of node selector to constrain a pod to only be able to run on particular
node(s).
|
String |
getPodName() |
int |
getRPCPort() |
String |
getServiceAccount() |
double |
getTaskManagerCPU() |
Map<String,Long> |
getTaskManagerExternalResources() |
String |
getTaskManagerMainContainerName() |
int |
getTaskManagerMemoryMB() |
List<Map<String,String>> |
getTolerations()
A collection of tolerations that are set to the JobManager and TaskManager Pod(s).
|
getClusterId, getCommonLabels, getConfigDirectory, getContainerEntrypoint, getEnvironmentsFromSecrets, getExistingHadoopConfigurationConfigMap, getFlinkConfDirInPod, getFlinkConfiguration, getFlinkLogDirInPod, getImage, getImagePullPolicy, getImagePullSecrets, getLocalHadoopConfigurationDirectory, getNamespace, getSecretNamesToMountPaths, hasLog4j, hasLogback
public static final String TASK_MANAGER_MAIN_CONTAINER_NAME
public KubernetesTaskManagerParameters(Configuration flinkConfig, String podName, String dynamicProperties, ContaineredTaskManagerParameters containeredTaskManagerParameters, Map<String,Long> taskManagerExternalResources)
public Map<String,String> getLabels()
KubernetesParameters
public Map<String,String> getNodeSelector()
KubernetesParameters
public Map<String,String> getEnvironments()
KubernetesParameters
public Map<String,String> getAnnotations()
KubernetesParameters
public List<Map<String,String>> getTolerations()
KubernetesParameters
public String getTaskManagerMainContainerName()
public String getPodName()
public int getTaskManagerMemoryMB()
public double getTaskManagerCPU()
public String getServiceAccount()
public int getRPCPort()
public String getDynamicProperties()
public ContaineredTaskManagerParameters getContaineredTaskManagerParameters()
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.