Package | Description |
---|---|
org.apache.flink.runtime.resourcemanager.registration | |
org.apache.flink.runtime.resourcemanager.slotmanager |
Modifier and Type | Class and Description |
---|---|
class |
WorkerRegistration<WorkerType extends ResourceIDRetrievable>
This class extends the
TaskExecutorConnection , adding the worker information. |
Modifier and Type | Method and Description |
---|---|
TaskExecutorConnection |
TaskManagerSlot.getTaskManagerConnection() |
TaskExecutorConnection |
TaskManagerRegistration.getTaskManagerConnection() |
TaskExecutorConnection |
TaskManagerSlotInformation.getTaskManagerConnection() |
Modifier and Type | Method and Description |
---|---|
void |
DefaultSlotTracker.addSlot(SlotID slotId,
ResourceProfile resourceProfile,
TaskExecutorConnection taskManagerConnection,
JobID assignedJob) |
boolean |
DeclarativeSlotManager.registerTaskManager(TaskExecutorConnection taskExecutorConnection,
SlotReport initialSlotReport)
Registers a new task manager at the slot manager.
|
boolean |
SlotManager.registerTaskManager(TaskExecutorConnection taskExecutorConnection,
SlotReport initialSlotReport)
Registers a new task manager at the slot manager.
|
boolean |
SlotManagerImpl.registerTaskManager(TaskExecutorConnection taskExecutorConnection,
SlotReport initialSlotReport)
Registers a new task manager at the slot manager.
|
Constructor and Description |
---|
TaskManagerRegistration(TaskExecutorConnection taskManagerConnection,
Collection<SlotID> slots) |
TaskManagerSlot(SlotID slotId,
ResourceProfile resourceProfile,
TaskExecutorConnection taskManagerConnection) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.