Class TaskExecutorConnection
- java.lang.Object
-
- org.apache.flink.runtime.resourcemanager.registration.TaskExecutorConnection
-
- Direct Known Subclasses:
WorkerRegistration
public class TaskExecutorConnection extends Object
This class is responsible for grouping the TaskExecutorGateway and the InstanceID of a registered task executor.
-
-
Constructor Summary
Constructors Constructor Description TaskExecutorConnection(ResourceID resourceID, TaskExecutorGateway taskExecutorGateway)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description InstanceID
getInstanceID()
ResourceID
getResourceID()
TaskExecutorGateway
getTaskExecutorGateway()
-
-
-
Constructor Detail
-
TaskExecutorConnection
public TaskExecutorConnection(ResourceID resourceID, TaskExecutorGateway taskExecutorGateway)
-
-
Method Detail
-
getResourceID
public ResourceID getResourceID()
-
getInstanceID
public InstanceID getInstanceID()
-
getTaskExecutorGateway
public TaskExecutorGateway getTaskExecutorGateway()
-
-