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

Class KubernetesJobManagerFactory

java.lang.Object

org.apache.flink.kubernetes.kubeclient.factory.KubernetesJobManagerFactory

public class KubernetesJobManagerFactory
extends Object

Utility class for constructing all the Kubernetes components on the client-side. This can include the Deployment, the ConfigMap(s), and the Service(s).

Constructor Summary

Constructors

Constructor	Description
KubernetesJobManagerFactory()

Method Summary

Modifier and Type	Method	Description
static KubernetesJobManagerSpecification	buildKubernetesJobManagerSpecification(FlinkPod podTemplate, KubernetesJobManagerParameters kubernetesJobManagerParameters)

Methods inherited from class java.lang.Object

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

Constructor Detail

KubernetesJobManagerFactory

public KubernetesJobManagerFactory()

Method Detail

buildKubernetesJobManagerSpecification

public static KubernetesJobManagerSpecification buildKubernetesJobManagerSpecification(FlinkPod podTemplate,
                                                                                       KubernetesJobManagerParameters kubernetesJobManagerParameters)
                                                                                throws IOException

Throws:

IOException