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

Class StandaloneKubernetesJobManagerParameters

  • All Implemented Interfaces:
    org.apache.flink.kubernetes.kubeclient.parameters.KubernetesParameters
    public class StandaloneKubernetesJobManagerParameters
extends org.apache.flink.kubernetes.kubeclient.parameters.KubernetesJobManagerParameters
    A Utility class that helps to parse, verify and manage the Kubernetes parameters that are used for constructing the JobManager deployment used for standalone cluster deployments.

    • Field Summary

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

        flinkConfig

    • Constructor Summary

      Constructors 
      Constructor Description
      StandaloneKubernetesJobManagerParameters​(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.lang.Boolean getAllowNonRestoredState()  
      java.util.Map<java.lang.String,​java.lang.String> getCommonLabels()  
      java.util.List<java.lang.String> getJobSpecArgs()  
      java.util.Map<java.lang.String,​java.lang.String> getLabels()  
      java.lang.String getMainClass()  
      java.lang.String getSavepointPath()  
      java.util.Map<java.lang.String,​java.lang.String> getSelectors()  
      boolean isApplicationCluster()  
      boolean isHAEnabled()  
      boolean isInternalServiceEnabled()  
      boolean isPipelineClasspathDefined()  

      • Methods inherited from class org.apache.flink.kubernetes.kubeclient.parameters.KubernetesJobManagerParameters

        getAnnotations, getBlobServerPort, getEntrypointArgs, getEntrypointClass, getEnvironments, getJobManagerCPU, getJobManagerCPULimitFactor, getJobManagerMemoryLimitFactor, getJobManagerMemoryMB, getNodeSelector, getOwnerReference, getPodTemplateFilePath, getReplicas, getRestBindPort, getRestPort, getRestServiceAnnotations, getRestServiceExposedType, getRPCPort, getServiceAccount, getTolerations, getUserArtifactsBaseDir

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

        getClusterId, 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

      • StandaloneKubernetesJobManagerParameters

        public StandaloneKubernetesJobManagerParameters​(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()
        Specified by:
        getLabels in interface org.apache.flink.kubernetes.kubeclient.parameters.KubernetesParameters
        Overrides:
        getLabels in class org.apache.flink.kubernetes.kubeclient.parameters.KubernetesJobManagerParameters

      • getSelectors

        public java.util.Map<java.lang.String,​java.lang.String> getSelectors()
        Specified by:
        getSelectors in interface org.apache.flink.kubernetes.kubeclient.parameters.KubernetesParameters
        Overrides:
        getSelectors in class org.apache.flink.kubernetes.kubeclient.parameters.KubernetesJobManagerParameters

      • getCommonLabels

        public java.util.Map<java.lang.String,​java.lang.String> getCommonLabels()
        Specified by:
        getCommonLabels in interface org.apache.flink.kubernetes.kubeclient.parameters.KubernetesParameters
        Overrides:
        getCommonLabels in class org.apache.flink.kubernetes.kubeclient.parameters.AbstractKubernetesParameters

      • isInternalServiceEnabled

        public boolean isInternalServiceEnabled()
        Overrides:
        isInternalServiceEnabled in class org.apache.flink.kubernetes.kubeclient.parameters.KubernetesJobManagerParameters

      • isApplicationCluster

        public boolean isApplicationCluster()

      • getMainClass

        public java.lang.String getMainClass()

      • getAllowNonRestoredState

        public java.lang.Boolean getAllowNonRestoredState()

      • getSavepointPath

        public java.lang.String getSavepointPath()

      • isPipelineClasspathDefined

        public boolean isPipelineClasspathDefined()

      • getJobSpecArgs

        public java.util.List<java.lang.String> getJobSpecArgs()

      • isHAEnabled

        public boolean isHAEnabled()