public class KubernetesJobManagerParameters extends AbstractKubernetesParameters
Modifier and Type | Field and Description |
---|---|
static String |
JOB_MANAGER_MAIN_CONTAINER_NAME |
flinkConfig
Constructor and Description |
---|
KubernetesJobManagerParameters(Configuration flinkConfig,
ClusterSpecification clusterSpecification) |
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.
|
int |
getBlobServerPort() |
String |
getEntrypointClass() |
Map<String,String> |
getEnvironments()
A collection of customized environments that are attached to the JobManager and TaskManager
Container(s).
|
double |
getJobManagerCPU() |
String |
getJobManagerMainContainerName() |
int |
getJobManagerMemoryMB() |
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).
|
int |
getRestBindPort() |
int |
getRestPort() |
Map<String,String> |
getRestServiceAnnotations() |
KubernetesConfigOptions.ServiceExposedType |
getRestServiceExposedType() |
int |
getRPCPort() |
String |
getServiceAccount() |
List<Map<String,String>> |
getTolerations()
A collection of tolerations that are set to the JobManager and TaskManager Pod(s).
|
boolean |
isInternalServiceEnabled() |
getClusterId, getCommonLabels, getConfigDirectory, getContainerEntrypoint, getExistingHadoopConfigurationConfigMap, getFlinkConfDirInPod, getFlinkConfiguration, getFlinkLogDirInPod, getImage, getImagePullPolicy, getImagePullSecrets, getLocalHadoopConfigurationDirectory, getNamespace, hasLog4j, hasLogback
public static final String JOB_MANAGER_MAIN_CONTAINER_NAME
public KubernetesJobManagerParameters(Configuration flinkConfig, ClusterSpecification clusterSpecification)
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 getJobManagerMainContainerName()
public int getJobManagerMemoryMB()
public double getJobManagerCPU()
public int getRestPort()
public int getRestBindPort()
public int getRPCPort()
public int getBlobServerPort()
public String getServiceAccount()
public String getEntrypointClass()
public KubernetesConfigOptions.ServiceExposedType getRestServiceExposedType()
public boolean isInternalServiceEnabled()
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.