Uses of Class
org.apache.flink.kubernetes.operator.api.status.FlinkDeploymentStatus
-
-
Uses of FlinkDeploymentStatus in org.apache.flink.kubernetes.operator.api
Methods in org.apache.flink.kubernetes.operator.api that return FlinkDeploymentStatus Modifier and Type Method Description FlinkDeploymentStatus
FlinkDeployment. initStatus()
-
Uses of FlinkDeploymentStatus in org.apache.flink.kubernetes.operator.api.listener
Method parameters in org.apache.flink.kubernetes.operator.api.listener with type arguments of type FlinkDeploymentStatus Modifier and Type Method Description void
FlinkResourceListener. onDeploymentStatusUpdate(FlinkResourceListener.StatusUpdateContext<FlinkDeployment,FlinkDeploymentStatus> ctx)
-
Uses of FlinkDeploymentStatus in org.apache.flink.kubernetes.operator.controller
Constructor parameters in org.apache.flink.kubernetes.operator.controller with type arguments of type FlinkDeploymentStatus Constructor Description FlinkDeploymentController(FlinkConfigManager configManager, java.util.Set<FlinkResourceValidator> validators, ReconcilerFactory reconcilerFactory, FlinkDeploymentObserverFactory observerFactory, StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> statusRecorder, EventRecorder eventRecorder)
-
Uses of FlinkDeploymentStatus in org.apache.flink.kubernetes.operator.observer.deployment
Constructor parameters in org.apache.flink.kubernetes.operator.observer.deployment with type arguments of type FlinkDeploymentStatus Constructor Description FlinkDeploymentObserverFactory(FlinkServiceFactory flinkServiceFactory, FlinkConfigManager configManager, StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> statusRecorder, EventRecorder eventRecorder)
-
Uses of FlinkDeploymentStatus in org.apache.flink.kubernetes.operator.reconciler.deployment
Methods in org.apache.flink.kubernetes.operator.reconciler.deployment with parameters of type FlinkDeploymentStatus Modifier and Type Method Description protected void
ApplicationReconciler. deploy(FlinkDeployment relatedResource, FlinkDeploymentSpec spec, FlinkDeploymentStatus status, io.javaoperatorsdk.operator.api.reconciler.Context<?> ctx, org.apache.flink.configuration.Configuration deployConfig, java.util.Optional<java.lang.String> savepoint, boolean requireHaMetadata)
protected void
SessionReconciler. deploy(FlinkDeployment cr, FlinkDeploymentSpec spec, FlinkDeploymentStatus status, io.javaoperatorsdk.operator.api.reconciler.Context<?> ctx, org.apache.flink.configuration.Configuration deployConfig, java.util.Optional<java.lang.String> savepoint, boolean requireHaMetadata)
Constructor parameters in org.apache.flink.kubernetes.operator.reconciler.deployment with type arguments of type FlinkDeploymentStatus Constructor Description ApplicationReconciler(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, FlinkService flinkService, FlinkConfigManager configManager, EventRecorder eventRecorder, StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> statusRecorder)
ReconcilerFactory(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, FlinkServiceFactory flinkServiceFactory, FlinkConfigManager configManager, EventRecorder eventRecorder, StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> deploymentStatusRecorder)
SessionReconciler(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, FlinkService flinkService, FlinkConfigManager configManager, EventRecorder eventRecorder, StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> statusRecorder)
-
Uses of FlinkDeploymentStatus in org.apache.flink.kubernetes.operator.service
Methods in org.apache.flink.kubernetes.operator.service with parameters of type FlinkDeploymentStatus Modifier and Type Method Description void
AbstractFlinkService. deleteClusterDeployment(io.fabric8.kubernetes.api.model.ObjectMeta meta, FlinkDeploymentStatus status, boolean deleteHaData)
void
FlinkService. deleteClusterDeployment(io.fabric8.kubernetes.api.model.ObjectMeta meta, FlinkDeploymentStatus status, boolean deleteHaData)
protected void
AbstractFlinkService. updateStatusAfterClusterDeletion(FlinkDeploymentStatus status)
-