Package | Description |
---|---|
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.jobmaster.slotpool |
Modifier and Type | Class and Description |
---|---|
class |
RpcTaskManagerGateway
Implementation of the
TaskManagerGateway for Flink's RPC system. |
Modifier and Type | Method and Description |
---|---|
TaskManagerGateway |
LogicalSlot.getTaskManagerGateway()
Return the TaskManager gateway to talk to the TaskManager.
|
TaskManagerGateway |
SlotContext.getTaskManagerGateway()
Gets the actor gateway that can be used to send messages to the TaskManager.
|
Modifier and Type | Method and Description |
---|---|
TaskManagerGateway |
SingleLogicalSlot.getTaskManagerGateway() |
Modifier and Type | Method and Description |
---|---|
Collection<SlotOffer> |
BlocklistDeclarativeSlotPool.offerSlots(Collection<? extends SlotOffer> offers,
TaskManagerLocation taskManagerLocation,
TaskManagerGateway taskManagerGateway,
long currentTime) |
Collection<SlotOffer> |
DefaultDeclarativeSlotPool.offerSlots(Collection<? extends SlotOffer> offers,
TaskManagerLocation taskManagerLocation,
TaskManagerGateway taskManagerGateway,
long currentTime) |
Collection<SlotOffer> |
DeclarativeSlotPool.offerSlots(Collection<? extends SlotOffer> offers,
TaskManagerLocation taskManagerLocation,
TaskManagerGateway taskManagerGateway,
long currentTime)
Offers slots to this slot pool.
|
Collection<SlotOffer> |
SlotPool.offerSlots(TaskManagerLocation taskManagerLocation,
TaskManagerGateway taskManagerGateway,
Collection<SlotOffer> offers)
Offers multiple slots to the
SlotPool . |
Collection<SlotOffer> |
SlotPoolService.offerSlots(TaskManagerLocation taskManagerLocation,
TaskManagerGateway taskManagerGateway,
Collection<SlotOffer> offers)
Offers multiple slots to the
SlotPoolService . |
Collection<SlotOffer> |
DeclarativeSlotPoolService.offerSlots(TaskManagerLocation taskManagerLocation,
TaskManagerGateway taskManagerGateway,
Collection<SlotOffer> offers) |
Collection<SlotOffer> |
DeclarativeSlotPoolBridge.offerSlots(TaskManagerLocation taskManagerLocation,
TaskManagerGateway taskManagerGateway,
Collection<SlotOffer> offers) |
Collection<SlotOffer> |
BlocklistDeclarativeSlotPool.registerSlots(Collection<? extends SlotOffer> slots,
TaskManagerLocation taskManagerLocation,
TaskManagerGateway taskManagerGateway,
long currentTime) |
Collection<SlotOffer> |
DefaultDeclarativeSlotPool.registerSlots(Collection<? extends SlotOffer> slots,
TaskManagerLocation taskManagerLocation,
TaskManagerGateway taskManagerGateway,
long currentTime) |
Collection<SlotOffer> |
DeclarativeSlotPool.registerSlots(Collection<? extends SlotOffer> slots,
TaskManagerLocation taskManagerLocation,
TaskManagerGateway taskManagerGateway,
long currentTime)
Registers the given set of slots at the slot pool.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.