Class StandaloneKubernetesTaskManagerParameters
- java.lang.Object
-
- org.apache.flink.kubernetes.kubeclient.parameters.AbstractKubernetesParameters
-
- org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters
-
- All Implemented Interfaces:
org.apache.flink.kubernetes.kubeclient.parameters.KubernetesParameters
public class StandaloneKubernetesTaskManagerParameters extends org.apache.flink.kubernetes.kubeclient.parameters.AbstractKubernetesParameters
A utility class that helps to parse, verify and manage the Kubernetes parameters that are used for constructing the TaskManager deployment used for standalone deployments.
-
-
Constructor Summary
Constructors Constructor Description StandaloneKubernetesTaskManagerParameters(org.apache.flink.configuration.Configuration flinkConfig, org.apache.flink.client.deployment.ClusterSpecification clusterSpecification)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.Map<java.lang.String,java.lang.String>
getAnnotations()
double
getCpuLimitFactor()
java.util.Map<java.lang.String,java.lang.String>
getEnvironments()
java.util.Map<java.lang.String,java.lang.String>
getLabels()
double
getMemoryLimitFactor()
java.util.Map<java.lang.String,java.lang.String>
getNodeSelector()
java.util.List<java.util.Map<java.lang.String,java.lang.String>>
getOwnerReference()
java.util.Optional<java.io.File>
getPodTemplateFilePath()
int
getReplicas()
int
getRPCPort()
java.util.Map<java.lang.String,java.lang.String>
getSelectors()
java.lang.String
getServiceAccount()
double
getTaskManagerCPU()
int
getTaskManagerMemoryMB()
java.util.List<java.util.Map<java.lang.String,java.lang.String>>
getTolerations()
-
Methods inherited from class org.apache.flink.kubernetes.kubeclient.parameters.AbstractKubernetesParameters
getClusterId, getCommonLabels, getConfigDirectory, getContainerEntrypoint, getEnvironmentsFromSecrets, getExistingHadoopConfigurationConfigMap, getFlinkConfDirInPod, getFlinkConfiguration, getFlinkLogDirInPod, getImage, getImagePullPolicy, getImagePullSecrets, getLocalHadoopConfigurationDirectory, getNamespace, getSecretNamesToMountPaths, hasLog4j, hasLogback, isHostNetworkEnabled
-
-
-
-
Method Detail
-
getLabels
public java.util.Map<java.lang.String,java.lang.String> getLabels()
-
getSelectors
public java.util.Map<java.lang.String,java.lang.String> getSelectors()
-
getNodeSelector
public java.util.Map<java.lang.String,java.lang.String> getNodeSelector()
-
getEnvironments
public java.util.Map<java.lang.String,java.lang.String> getEnvironments()
-
getAnnotations
public java.util.Map<java.lang.String,java.lang.String> getAnnotations()
-
getTolerations
public java.util.List<java.util.Map<java.lang.String,java.lang.String>> getTolerations()
-
getReplicas
public int getReplicas()
-
getServiceAccount
public java.lang.String getServiceAccount()
-
getTaskManagerMemoryMB
public int getTaskManagerMemoryMB()
-
getTaskManagerCPU
public double getTaskManagerCPU()
-
getRPCPort
public int getRPCPort()
-
getPodTemplateFilePath
public java.util.Optional<java.io.File> getPodTemplateFilePath()
-
getMemoryLimitFactor
public double getMemoryLimitFactor()
-
getCpuLimitFactor
public double getCpuLimitFactor()
-
getOwnerReference
public java.util.List<java.util.Map<java.lang.String,java.lang.String>> getOwnerReference()
-
-