Uses of Class
org.apache.flink.kubernetes.operator.observer.deployment.FlinkDeploymentObserverContext
-
Packages that use FlinkDeploymentObserverContext Package Description org.apache.flink.kubernetes.operator.observer.deployment -
-
Uses of FlinkDeploymentObserverContext in org.apache.flink.kubernetes.operator.observer.deployment
Methods in org.apache.flink.kubernetes.operator.observer.deployment that return FlinkDeploymentObserverContext Modifier and Type Method Description protected FlinkDeploymentObserverContext
AbstractFlinkDeploymentObserver. getObserverContext(FlinkDeployment resource, io.javaoperatorsdk.operator.api.reconciler.Context<?> context)
Methods in org.apache.flink.kubernetes.operator.observer.deployment with parameters of type FlinkDeploymentObserverContext Modifier and Type Method Description protected abstract void
AbstractFlinkDeploymentObserver. observeFlinkCluster(FlinkDeployment flinkApp, io.javaoperatorsdk.operator.api.reconciler.Context<?> context, FlinkDeploymentObserverContext observerContext)
Observe the flinkApp status when the cluster is ready.protected void
ApplicationObserver. observeFlinkCluster(FlinkDeployment flinkApp, io.javaoperatorsdk.operator.api.reconciler.Context<?> context, FlinkDeploymentObserverContext observerContext)
void
SessionObserver. observeFlinkCluster(FlinkDeployment deployment, io.javaoperatorsdk.operator.api.reconciler.Context<?> context, FlinkDeploymentObserverContext observerContext)
void
AbstractFlinkDeploymentObserver. observeInternal(FlinkDeployment flinkDep, io.javaoperatorsdk.operator.api.reconciler.Context<?> context, FlinkDeploymentObserverContext observerContext)
protected void
AbstractFlinkDeploymentObserver. updateStatusToDeployedIfAlreadyUpgraded(FlinkDeployment flinkDep, io.javaoperatorsdk.operator.api.reconciler.Context<?> context, FlinkDeploymentObserverContext observerContext)
-