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<org.apache.flink.kubernetes.operator.api.FlinkDeployment,org.apache.flink.kubernetes.operator.api.status.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(org.apache.flink.kubernetes.operator.api.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<org.apache.flink.kubernetes.operator.api.FlinkDeployment,org.apache.flink.kubernetes.operator.api.status.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<org.apache.flink.kubernetes.operator.api.FlinkSessionJob,org.apache.flink.kubernetes.operator.api.status.FlinkSessionJobStatus> statusRecorder)
-