Package org.apache.flink.kubernetes.operator.utils

Class EventSourceUtils

java.lang.Object

org.apache.flink.kubernetes.operator.utils.EventSourceUtils

public class EventSourceUtils
extends java.lang.Object

Utility class to locate secondary resources.

Constructor Summary

Constructors

Constructor	Description
EventSourceUtils()

Method Summary

Modifier and Type	Method	Description
static io.javaoperatorsdk.operator.processing.event.source.informer.InformerEventSource<io.fabric8.kubernetes.api.model.apps.Deployment,FlinkDeployment>	getDeploymentInformerEventSource(io.javaoperatorsdk.operator.api.reconciler.EventSourceContext<FlinkDeployment> context)
static io.javaoperatorsdk.operator.processing.event.source.informer.InformerEventSource<FlinkDeployment,FlinkSessionJob>	getFlinkDeploymentInformerEventSource(io.javaoperatorsdk.operator.api.reconciler.EventSourceContext<FlinkSessionJob> context)
static io.javaoperatorsdk.operator.processing.event.source.informer.InformerEventSource<FlinkSessionJob,FlinkDeployment>	getSessionJobInformerEventSource(io.javaoperatorsdk.operator.api.reconciler.EventSourceContext<FlinkDeployment> context)

Methods inherited from class java.lang.Object

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

Constructor Detail

EventSourceUtils

public EventSourceUtils()

Method Detail

getDeploymentInformerEventSource

public static io.javaoperatorsdk.operator.processing.event.source.informer.InformerEventSource<io.fabric8.kubernetes.api.model.apps.Deployment,FlinkDeployment> getDeploymentInformerEventSource(io.javaoperatorsdk.operator.api.reconciler.EventSourceContext<FlinkDeployment> context)

getSessionJobInformerEventSource

public static io.javaoperatorsdk.operator.processing.event.source.informer.InformerEventSource<FlinkSessionJob,FlinkDeployment> getSessionJobInformerEventSource(io.javaoperatorsdk.operator.api.reconciler.EventSourceContext<FlinkDeployment> context)

getFlinkDeploymentInformerEventSource

public static io.javaoperatorsdk.operator.processing.event.source.informer.InformerEventSource<FlinkDeployment,FlinkSessionJob> getFlinkDeploymentInformerEventSource(io.javaoperatorsdk.operator.api.reconciler.EventSourceContext<FlinkSessionJob> context)