org.apache.flink.runtime.resourcemanager.registration

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 and Description
TaskExecutorConnection(ResourceID resourceID, TaskExecutorGateway taskExecutorGateway)

Method Summary

Modifier and Type	Method and Description
InstanceID	getInstanceID()
ResourceID	getResourceID()
TaskExecutorGateway	getTaskExecutorGateway()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TaskExecutorConnection

public TaskExecutorConnection(ResourceID resourceID,
                              TaskExecutorGateway taskExecutorGateway)

Method Detail

getResourceID

public ResourceID getResourceID()

getInstanceID

public InstanceID getInstanceID()

getTaskExecutorGateway

public TaskExecutorGateway getTaskExecutorGateway()