Package | Description |
---|---|
org.apache.flink.kubernetes.highavailability | |
org.apache.flink.runtime.leaderretrieval |
Modifier and Type | Class and Description |
---|---|
class |
KubernetesLeaderRetrievalDriverFactory
LeaderRetrievalDriverFactory implementation for Kubernetes. |
Modifier and Type | Class and Description |
---|---|
class |
ZooKeeperLeaderRetrievalDriverFactory
LeaderRetrievalDriverFactory implementation for Zookeeper. |
Constructor and Description |
---|
DefaultLeaderRetrievalService(LeaderRetrievalDriverFactory leaderRetrievalDriverFactory)
Creates a default leader retrieval service with specified
LeaderRetrievalDriverFactory . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.