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

Class KubernetesJobManagerParameters

  • All Implemented Interfaces:
    KubernetesParameters
    public class KubernetesJobManagerParameters
extends AbstractKubernetesParameters
    A utility class helps parse, verify, and manage the Kubernetes side parameters that are used for constructing the JobManager Pod and all accompanying resources connected to it.

    • Constructor Detail

      • KubernetesJobManagerParameters

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

    • Method Detail

      • getLabels

        public Map<String,​String> getLabels()
        Description copied from interface: KubernetesParameters
        A collection of labels that are attached to the JobManager and TaskManager Pod(s).

      • getSelectors

        public Map<String,​String> getSelectors()
        Description copied from interface: KubernetesParameters
        A stable subset of labels attached to the resource to select the related resources.

      • getNodeSelector

        public Map<String,​String> getNodeSelector()
        Description copied from interface: KubernetesParameters
        A collection of node selector to constrain a pod to only be able to run on particular node(s).

      • getEnvironments

        public Map<String,​String> getEnvironments()
        Description copied from interface: KubernetesParameters
        A collection of customized environments that are attached to the JobManager and TaskManager Container(s).

      • getAnnotations

        public Map<String,​String> getAnnotations()
        Description copied from interface: KubernetesParameters
        A map of user-specified annotations that are set to the JobManager and TaskManager pods.

      • getTolerations

        public List<Map<String,​String>> getTolerations()
        Description copied from interface: KubernetesParameters
        A collection of tolerations that are set to the JobManager and TaskManager Pod(s). Kubernetes taints and tolerations work together to ensure that pods are not scheduled onto inappropriate nodes.

      • getPodTemplateFilePath

        public Optional<File> getPodTemplateFilePath()

      • getRestServiceAnnotations

        public Map<String,​String> getRestServiceAnnotations()

      • getInternalServiceAnnotations

        public Map<String,​String> getInternalServiceAnnotations()

      • getJobManagerMemoryMB

        public int getJobManagerMemoryMB()

      • getJobManagerCPU

        public double getJobManagerCPU()

      • getJobManagerCPULimitFactor

        public double getJobManagerCPULimitFactor()

      • getJobManagerMemoryLimitFactor

        public double getJobManagerMemoryLimitFactor()

      • getRestPort

        public int getRestPort()

      • getRestBindPort

        public int getRestBindPort()

      • getRPCPort

        public int getRPCPort()

      • getBlobServerPort

        public int getBlobServerPort()

      • getServiceAccount

        public String getServiceAccount()

      • getEntrypointClass

        public String getEntrypointClass()

      • isInternalServiceEnabled

        public boolean isInternalServiceEnabled()

      • getReplicas

        public int getReplicas()

      • getEntrypointArgs

        public String getEntrypointArgs()

      • getUserArtifactsBaseDir

        public String getUserArtifactsBaseDir()