Uses of Class
org.apache.flink.kubernetes.operator.service.FlinkServiceFactory
-
-
Uses of FlinkServiceFactory in org.apache.flink.kubernetes.operator.observer.deployment
Constructors in org.apache.flink.kubernetes.operator.observer.deployment with parameters of type FlinkServiceFactory Constructor Description FlinkDeploymentObserverFactory(FlinkServiceFactory flinkServiceFactory, FlinkConfigManager configManager, StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> statusRecorder, EventRecorder eventRecorder)
-
Uses of FlinkServiceFactory in org.apache.flink.kubernetes.operator.observer.sessionjob
Constructors in org.apache.flink.kubernetes.operator.observer.sessionjob with parameters of type FlinkServiceFactory Constructor Description FlinkSessionJobObserver(FlinkServiceFactory flinkServiceFactory, FlinkConfigManager configManager, EventRecorder eventRecorder)
FlinkSessionJobObserverContext(FlinkSessionJob resource, io.javaoperatorsdk.operator.api.reconciler.Context<?> resourceContext, FlinkServiceFactory flinkServiceFactory, FlinkConfigManager configManager)
-
Uses of FlinkServiceFactory in org.apache.flink.kubernetes.operator.reconciler.deployment
Constructors in org.apache.flink.kubernetes.operator.reconciler.deployment with parameters of type FlinkServiceFactory Constructor Description ReconcilerFactory(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, FlinkServiceFactory flinkServiceFactory, FlinkConfigManager configManager, EventRecorder eventRecorder, StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> deploymentStatusRecorder)
-
Uses of FlinkServiceFactory in org.apache.flink.kubernetes.operator.reconciler.sessionjob
Constructors in org.apache.flink.kubernetes.operator.reconciler.sessionjob with parameters of type FlinkServiceFactory Constructor Description SessionJobReconciler(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, FlinkServiceFactory flinkServiceFactory, FlinkConfigManager configManager, EventRecorder eventRecorder, StatusRecorder<FlinkSessionJob,FlinkSessionJobStatus> statusRecorder)
-