Package org.apache.flink.kubernetes.operator.kubeclient.parameters

Class 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.

    • Field Summary

      • Fields inherited from class org.apache.flink.kubernetes.kubeclient.parameters.AbstractKubernetesParameters

        flinkConfig

    • 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

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • StandaloneKubernetesTaskManagerParameters

        public StandaloneKubernetesTaskManagerParameters​(org.apache.flink.configuration.Configuration flinkConfig,
                                                 org.apache.flink.client.deployment.ClusterSpecification clusterSpecification)

    • 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()