Package | Description |
---|---|
org.apache.flink.kubernetes | |
org.apache.flink.kubernetes.kubeclient | |
org.apache.flink.kubernetes.kubeclient.resources |
Modifier and Type | Class and Description |
---|---|
class |
KubernetesResourceManager
Kubernetes specific implementation of the
ResourceManager . |
Modifier and Type | Method and Description |
---|---|
KubernetesWatch |
FlinkKubeClient.watchPodsAndDoCallback(Map<String,String> labels,
FlinkKubeClient.PodCallbackHandler podCallbackHandler)
Watch the pods selected by labels and do the
FlinkKubeClient.PodCallbackHandler . |
KubernetesWatch |
Fabric8FlinkKubeClient.watchPodsAndDoCallback(Map<String,String> labels,
FlinkKubeClient.PodCallbackHandler podCallbackHandler) |
Constructor and Description |
---|
KubernetesPodsWatcher(Configuration configuration,
FlinkKubeClient.PodCallbackHandler callbackHandler) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.