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> |
SlotPool.offerSlots(TaskManagerLocation taskManagerLocation,
TaskManagerGateway taskManagerGateway,
Collection<SlotOffer> offers)
Offers multiple slots to the
SlotPool . |
Collection<SlotOffer> |
SlotPoolImpl.offerSlots(TaskManagerLocation taskManagerLocation,
TaskManagerGateway taskManagerGateway,
Collection<SlotOffer> offers) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.