public interface KubernetesParameters
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.
|
String |
getClusterId() |
Map<String,String> |
getCommonLabels()
A common collection of labels that are attached to every created Kubernetes resources.
|
String |
getConfigDirectory() |
String |
getContainerEntrypoint()
The docker entrypoint that starts processes in the container.
|
Map<String,String> |
getEnvironments()
A collection of customized environments that are attached to the JobManager and TaskManager
Container(s).
|
List<Map<String,String>> |
getEnvironmentsFromSecrets()
A collection of customized environments that are attached to the JobManager and TaskManager
container(s).
|
Optional<String> |
getExistingHadoopConfigurationConfigMap()
The existing ConfigMap containing custom Hadoop configuration.
|
String |
getFlinkConfDirInPod()
Directory in Pod that stores the flink-conf.yaml, log4j.properties, and the logback.xml.
|
String |
getFlinkLogDirInPod()
Directory in Pod that saves the log files.
|
String |
getImage() |
KubernetesConfigOptions.ImagePullPolicy |
getImagePullPolicy() |
io.fabric8.kubernetes.api.model.LocalObjectReference[] |
getImagePullSecrets() |
Map<String,String> |
getLabels()
A collection of labels that are attached to the JobManager and TaskManager Pod(s).
|
Optional<String> |
getLocalHadoopConfigurationDirectory()
The local directory to locate the custom Hadoop configuration.
|
String |
getNamespace() |
Map<String,String> |
getNodeSelector()
A collection of node selector to constrain a pod to only be able to run on particular
node(s).
|
Map<String,String> |
getSecretNamesToMountPaths()
A collection of secret and path pairs that are mounted to the JobManager and TaskManager
container(s).
|
List<Map<String,String>> |
getTolerations()
A collection of tolerations that are set to the JobManager and TaskManager Pod(s).
|
boolean |
hasLog4j()
Whether the log4j.properties is located.
|
boolean |
hasLogback()
Whether the logback.xml is located.
|
String getConfigDirectory()
String getClusterId()
String getNamespace()
String getImage()
KubernetesConfigOptions.ImagePullPolicy getImagePullPolicy()
io.fabric8.kubernetes.api.model.LocalObjectReference[] getImagePullSecrets()
Map<String,String> getCommonLabels()
Map<String,String> getLabels()
Map<String,String> getNodeSelector()
Map<String,String> getEnvironments()
Map<String,String> getAnnotations()
List<Map<String,String>> getTolerations()
String getFlinkConfDirInPod()
String getFlinkLogDirInPod()
String getContainerEntrypoint()
boolean hasLogback()
boolean hasLog4j()
Optional<String> getExistingHadoopConfigurationConfigMap()
Optional<String> getLocalHadoopConfigurationDirectory()
Map<String,String> getSecretNamesToMountPaths()
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.