Uses of Class
org.apache.flink.runtime.resourcemanager.registration.TaskExecutorConnection

Packages that use TaskExecutorConnection

Package	Description
org.apache.flink.runtime.resourcemanager.registration
org.apache.flink.runtime.resourcemanager.slotmanager

Uses of TaskExecutorConnection in org.apache.flink.runtime.resourcemanager.registration

Subclasses of TaskExecutorConnection in org.apache.flink.runtime.resourcemanager.registration

Modifier and Type	Class and Description
class	WorkerRegistration<WorkerType extends ResourceIDRetrievable> This class extends the TaskExecutorConnection, adding the worker information.

Uses of TaskExecutorConnection in org.apache.flink.runtime.resourcemanager.slotmanager

Methods in org.apache.flink.runtime.resourcemanager.slotmanager that return TaskExecutorConnection

Modifier and Type	Method and Description
TaskExecutorConnection	TaskManagerInfo.getTaskExecutorConnection() Get the taskExecutorConnection.
TaskExecutorConnection	FineGrainedTaskManagerRegistration.getTaskExecutorConnection()
TaskExecutorConnection	TaskManagerRegistration.getTaskManagerConnection()
TaskExecutorConnection	FineGrainedTaskManagerSlot.getTaskManagerConnection()
TaskExecutorConnection	TaskManagerSlotInformation.getTaskManagerConnection()

Methods in org.apache.flink.runtime.resourcemanager.slotmanager that return types with arguments of type TaskExecutorConnection

Modifier and Type	Method and Description
Collection<TaskExecutorConnection>	DefaultSlotTracker.getTaskExecutorsWithAllocatedSlotsForJob(JobID jobId)

Methods in org.apache.flink.runtime.resourcemanager.slotmanager with parameters of type TaskExecutorConnection

Modifier and Type	Method and Description
void	DefaultSlotTracker.addSlot(SlotID slotId, ResourceProfile resourceProfile, TaskExecutorConnection taskManagerConnection, JobID assignedJob)
void	FineGrainedTaskManagerTracker.addTaskManager(TaskExecutorConnection taskExecutorConnection, ResourceProfile totalResourceProfile, ResourceProfile defaultSlotResourceProfile)
boolean	SlotManager.registerTaskManager(TaskExecutorConnection taskExecutorConnection, SlotReport initialSlotReport, ResourceProfile totalResourceProfile, ResourceProfile defaultSlotResourceProfile) Registers a new task manager at the slot manager.
boolean	DeclarativeSlotManager.registerTaskManager(TaskExecutorConnection taskExecutorConnection, SlotReport initialSlotReport, ResourceProfile totalResourceProfile, ResourceProfile defaultSlotResourceProfile) Registers a new task manager at the slot manager.
boolean	FineGrainedSlotManager.registerTaskManager(TaskExecutorConnection taskExecutorConnection, SlotReport initialSlotReport, ResourceProfile totalResourceProfile, ResourceProfile defaultSlotResourceProfile) Registers a new task manager at the slot manager.

Constructors in org.apache.flink.runtime.resourcemanager.slotmanager with parameters of type TaskExecutorConnection

Constructor and Description
FineGrainedTaskManagerRegistration(TaskExecutorConnection taskManagerConnection, ResourceProfile totalResourceProfile, ResourceProfile defaultSlotResourceProfile)
FineGrainedTaskManagerSlot(AllocationID allocationId, JobID jobId, ResourceProfile resourceProfile, TaskExecutorConnection taskManagerConnection, org.apache.flink.runtime.resourcemanager.slotmanager.SlotState slotState)
TaskManagerRegistration(TaskExecutorConnection taskManagerConnection, Collection<SlotID> slots, ResourceProfile totalResourceProfile, ResourceProfile defaultSlotResourceProfile)