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

Class EventSourceUtils

  • public class EventSourceUtils
extends java.lang.Object
    Utility class to locate secondary resources.

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static io.javaoperatorsdk.operator.processing.event.source.informer.InformerEventSource<io.fabric8.kubernetes.api.model.apps.Deployment,​org.apache.flink.kubernetes.operator.api.FlinkDeployment> getDeploymentInformerEventSource​(io.javaoperatorsdk.operator.api.reconciler.EventSourceContext<org.apache.flink.kubernetes.operator.api.FlinkDeployment> context)  
      static io.javaoperatorsdk.operator.processing.event.source.informer.InformerEventSource<org.apache.flink.kubernetes.operator.api.FlinkDeployment,​org.apache.flink.kubernetes.operator.api.FlinkSessionJob> getFlinkDeploymentInformerEventSource​(io.javaoperatorsdk.operator.api.reconciler.EventSourceContext<org.apache.flink.kubernetes.operator.api.FlinkSessionJob> context)  
      static io.javaoperatorsdk.operator.processing.event.source.informer.InformerEventSource<org.apache.flink.kubernetes.operator.api.FlinkSessionJob,​org.apache.flink.kubernetes.operator.api.FlinkDeployment> getSessionJobInformerEventSource​(io.javaoperatorsdk.operator.api.reconciler.EventSourceContext<org.apache.flink.kubernetes.operator.api.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,​org.apache.flink.kubernetes.operator.api.FlinkDeployment> getDeploymentInformerEventSource​(io.javaoperatorsdk.operator.api.reconciler.EventSourceContext<org.apache.flink.kubernetes.operator.api.FlinkDeployment> context)

      • getSessionJobInformerEventSource

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

      • getFlinkDeploymentInformerEventSource

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