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 FlinkDeploymentObserverContextAbstractFlinkDeploymentObserver. getObserverContext(org.apache.flink.kubernetes.operator.api.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 voidAbstractFlinkDeploymentObserver. observeFlinkCluster(org.apache.flink.kubernetes.operator.api.FlinkDeployment flinkApp, io.javaoperatorsdk.operator.api.reconciler.Context<?> context, FlinkDeploymentObserverContext observerContext)Observe the flinkApp status when the cluster is ready.protected voidApplicationObserver. observeFlinkCluster(org.apache.flink.kubernetes.operator.api.FlinkDeployment flinkApp, io.javaoperatorsdk.operator.api.reconciler.Context<?> context, FlinkDeploymentObserverContext observerContext)voidSessionObserver. observeFlinkCluster(org.apache.flink.kubernetes.operator.api.FlinkDeployment deployment, io.javaoperatorsdk.operator.api.reconciler.Context<?> context, FlinkDeploymentObserverContext observerContext)voidAbstractFlinkDeploymentObserver. observeInternal(org.apache.flink.kubernetes.operator.api.FlinkDeployment flinkDep, io.javaoperatorsdk.operator.api.reconciler.Context<?> context, FlinkDeploymentObserverContext observerContext)protected voidAbstractFlinkDeploymentObserver. updateStatusToDeployedIfAlreadyUpgraded(org.apache.flink.kubernetes.operator.api.FlinkDeployment flinkDep, io.javaoperatorsdk.operator.api.reconciler.Context<?> context, FlinkDeploymentObserverContext observerContext)
-