Package org.apache.flink.kubernetes
Class KubernetesWorkerNode
- java.lang.Object
-
- org.apache.flink.kubernetes.KubernetesWorkerNode
-
- All Implemented Interfaces:
org.apache.flink.runtime.clusterframework.types.ResourceIDRetrievable
public class KubernetesWorkerNode extends Object implements org.apache.flink.runtime.clusterframework.types.ResourceIDRetrievable
A stored Kubernetes worker, which contains the kubernetes pod.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description longgetAttempt()org.apache.flink.runtime.clusterframework.types.ResourceIDgetResourceID()
-
-
-
Method Detail
-
getResourceID
public org.apache.flink.runtime.clusterframework.types.ResourceID getResourceID()
- Specified by:
getResourceIDin interfaceorg.apache.flink.runtime.clusterframework.types.ResourceIDRetrievable
-
getAttempt
public long getAttempt() throws org.apache.flink.runtime.resourcemanager.exceptions.ResourceManagerException- Throws:
org.apache.flink.runtime.resourcemanager.exceptions.ResourceManagerException
-
-