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

Class StandaloneKubernetesJobManagerFactory

java.lang.Object

org.apache.flink.kubernetes.operator.kubeclient.factory.StandaloneKubernetesJobManagerFactory

public class StandaloneKubernetesJobManagerFactory
extends java.lang.Object

Utility class for constructing all the Kubernetes for the JobManager deploying in standalone mode. This can include the Deployment, the ConfigMap(s), and the Service(s).

Constructor Summary

Constructors

Constructor	Description
StandaloneKubernetesJobManagerFactory()

Method Summary

Modifier and Type	Method	Description
static org.apache.flink.kubernetes.kubeclient.KubernetesJobManagerSpecification	buildKubernetesJobManagerSpecification(org.apache.flink.kubernetes.kubeclient.FlinkPod podTemplate, StandaloneKubernetesJobManagerParameters kubernetesJobManagerParameters)

Methods inherited from class java.lang.Object

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

Constructor Detail

StandaloneKubernetesJobManagerFactory

public StandaloneKubernetesJobManagerFactory()

Method Detail

buildKubernetesJobManagerSpecification

public static org.apache.flink.kubernetes.kubeclient.KubernetesJobManagerSpecification buildKubernetesJobManagerSpecification(org.apache.flink.kubernetes.kubeclient.FlinkPod podTemplate,
                                                                                                                              StandaloneKubernetesJobManagerParameters kubernetesJobManagerParameters)
                                                                                                                       throws java.io.IOException

Throws:

java.io.IOException