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	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	Description
TaskExecutorConnection	FineGrainedTaskManagerRegistration.getTaskExecutorConnection()
TaskExecutorConnection	TaskManagerInfo.getTaskExecutorConnection()	Get the taskExecutorConnection.
TaskExecutorConnection	FineGrainedTaskManagerSlot.getTaskManagerConnection()
TaskExecutorConnection	TaskManagerRegistration.getTaskManagerConnection()
TaskExecutorConnection	TaskManagerSlotInformation.getTaskManagerConnection()

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

Modifier and Type	Method	Description
Collection<TaskExecutorConnection>	DefaultSlotTracker.getTaskExecutorsWithAllocatedSlotsForJob(org.apache.flink.api.common.JobID jobId)

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

Modifier and Type	Method	Description
void	DefaultSlotTracker.addSlot(SlotID slotId, ResourceProfile resourceProfile, TaskExecutorConnection taskManagerConnection, org.apache.flink.api.common.JobID assignedJob)
void	FineGrainedTaskManagerTracker.addTaskManager(TaskExecutorConnection taskExecutorConnection, ResourceProfile totalResourceProfile, ResourceProfile defaultSlotResourceProfile)
SlotManager.RegistrationResult	DeclarativeSlotManager.registerTaskManager(TaskExecutorConnection taskExecutorConnection, SlotReport initialSlotReport, ResourceProfile totalResourceProfile, ResourceProfile defaultSlotResourceProfile)
SlotManager.RegistrationResult	FineGrainedSlotManager.registerTaskManager(TaskExecutorConnection taskExecutorConnection, SlotReport initialSlotReport, ResourceProfile totalResourceProfile, ResourceProfile defaultSlotResourceProfile)
SlotManager.RegistrationResult	SlotManager.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	Description
FineGrainedTaskManagerRegistration(TaskExecutorConnection taskManagerConnection, ResourceProfile totalResourceProfile, ResourceProfile defaultSlotResourceProfile)
FineGrainedTaskManagerSlot(AllocationID allocationId, org.apache.flink.api.common.JobID jobId, ResourceProfile resourceProfile, TaskExecutorConnection taskManagerConnection, org.apache.flink.runtime.resourcemanager.slotmanager.SlotState slotState)
TaskManagerRegistration(TaskExecutorConnection taskManagerConnection, Collection<SlotID> slots, ResourceProfile totalResourceProfile, ResourceProfile defaultSlotResourceProfile)