Uses of Interface
org.apache.flink.kubernetes.kubeclient.KubernetesConfigMapSharedWatcher
-
Packages that use KubernetesConfigMapSharedWatcher Package Description org.apache.flink.kubernetes.highavailability org.apache.flink.kubernetes.kubeclient org.apache.flink.kubernetes.kubeclient.resources -
-
Uses of KubernetesConfigMapSharedWatcher in org.apache.flink.kubernetes.highavailability
Constructors in org.apache.flink.kubernetes.highavailability with parameters of type KubernetesConfigMapSharedWatcher Constructor Description KubernetesLeaderElectionDriver(KubernetesLeaderElectionConfiguration leaderElectionConfiguration, FlinkKubeClient kubeClient, org.apache.flink.runtime.leaderelection.LeaderElectionDriver.Listener leaderElectionListener, KubernetesConfigMapSharedWatcher configMapSharedWatcher, Executor watchExecutor)KubernetesLeaderElectionDriverFactory(FlinkKubeClient kubeClient, KubernetesLeaderElectionConfiguration kubernetesLeaderElectionConfiguration, KubernetesConfigMapSharedWatcher configMapSharedWatcher, Executor watchExecutor)KubernetesLeaderRetrievalDriver(KubernetesConfigMapSharedWatcher configMapSharedWatcher, Executor watchExecutor, String configMapName, org.apache.flink.runtime.leaderretrieval.LeaderRetrievalEventHandler leaderRetrievalEventHandler, java.util.function.Function<KubernetesConfigMap,org.apache.flink.runtime.leaderelection.LeaderInformation> leaderInformationExtractor, org.apache.flink.runtime.rpc.FatalErrorHandler fatalErrorHandler)KubernetesLeaderRetrievalDriverFactory(KubernetesConfigMapSharedWatcher configMapSharedWatcher, Executor watchExecutor, String configMapName, String componentId) -
Uses of KubernetesConfigMapSharedWatcher in org.apache.flink.kubernetes.kubeclient
Methods in org.apache.flink.kubernetes.kubeclient that return KubernetesConfigMapSharedWatcher Modifier and Type Method Description KubernetesConfigMapSharedWatcherFabric8FlinkKubeClient. createConfigMapSharedWatcher(String name)KubernetesConfigMapSharedWatcherFlinkKubeClient. createConfigMapSharedWatcher(String name)Create a shared watcher for ConfigMaps with specified name. -
Uses of KubernetesConfigMapSharedWatcher in org.apache.flink.kubernetes.kubeclient.resources
Classes in org.apache.flink.kubernetes.kubeclient.resources that implement KubernetesConfigMapSharedWatcher Modifier and Type Class Description classKubernetesConfigMapSharedInformerThe shared informer forConfigMap, it can be used as a shared watcher.
-