Uses of Interface
org.apache.flink.runtime.jobmanager.slots.TaskManagerGateway

Packages that use TaskManagerGateway

Package	Description
org.apache.flink.runtime.instance
org.apache.flink.runtime.jobmanager.slots
org.apache.flink.runtime.jobmaster
org.apache.flink.runtime.jobmaster.slotpool

Uses of TaskManagerGateway in org.apache.flink.runtime.instance

Methods in org.apache.flink.runtime.instance that return TaskManagerGateway

Modifier and Type	Method and Description
TaskManagerGateway	SimpleSlotContext.getTaskManagerGateway()
TaskManagerGateway	Slot.getTaskManagerGateway() Gets the actor gateway that can be used to send messages to the TaskManager.
TaskManagerGateway	Instance.getTaskManagerGateway() Returns the InstanceGateway of this Instance.

Methods in org.apache.flink.runtime.instance with parameters of type TaskManagerGateway

Modifier and Type	Method and Description
InstanceID	InstanceManager.registerTaskManager(TaskManagerGateway taskManagerGateway, TaskManagerLocation taskManagerLocation, HardwareDescription resources, int numberOfSlots) Registers a task manager.

Constructors in org.apache.flink.runtime.instance with parameters of type TaskManagerGateway

Constructor and Description
Instance(TaskManagerGateway taskManagerGateway, TaskManagerLocation location, InstanceID id, HardwareDescription resources, int numberOfSlots) Constructs an instance reflecting a registered TaskManager.
SharedSlot(SlotOwner owner, TaskManagerLocation location, int slotNumber, TaskManagerGateway taskManagerGateway, SlotSharingGroupAssignment assignmentGroup) Creates a new shared slot that has no parent (is a root slot) and does not belong to any task group.
SharedSlot(SlotOwner owner, TaskManagerLocation location, int slotNumber, TaskManagerGateway taskManagerGateway, SlotSharingGroupAssignment assignmentGroup, SharedSlot parent, AbstractID groupId) Creates a new shared slot that has is a sub-slot of the given parent shared slot, and that belongs to the given task group.
SimpleSlot(SlotOwner owner, TaskManagerLocation location, int slotNumber, TaskManagerGateway taskManagerGateway) Creates a new simple slot that stands alone and does not belong to shared slot.
SimpleSlot(SlotOwner owner, TaskManagerLocation location, int slotNumber, TaskManagerGateway taskManagerGateway, SharedSlot parent, AbstractID groupID) Creates a new simple slot that belongs to the given shared slot and is identified by the given ID.
SimpleSlotContext(AllocationID allocationId, TaskManagerLocation taskManagerLocation, int physicalSlotNumber, TaskManagerGateway taskManagerGateway)
SimpleSlotContext(AllocationID allocationId, TaskManagerLocation taskManagerLocation, int physicalSlotNumber, TaskManagerGateway taskManagerGateway, ResourceProfile resourceProfile)
Slot(SlotOwner owner, TaskManagerLocation location, int slotNumber, TaskManagerGateway taskManagerGateway, SharedSlot parent, AbstractID groupID) Base constructor for slots.

Uses of TaskManagerGateway in org.apache.flink.runtime.jobmanager.slots

Classes in org.apache.flink.runtime.jobmanager.slots that implement TaskManagerGateway

Modifier and Type	Class and Description
class	ActorTaskManagerGateway Implementation of the TaskManagerGateway for ActorGateway.

Uses of TaskManagerGateway in org.apache.flink.runtime.jobmaster

Classes in org.apache.flink.runtime.jobmaster that implement TaskManagerGateway

Modifier and Type	Class and Description
class	RpcTaskManagerGateway Implementation of the TaskManagerGateway for Flink's RPC system.

Methods in org.apache.flink.runtime.jobmaster that return TaskManagerGateway

Modifier and Type	Method and Description
TaskManagerGateway	SlotContext.getTaskManagerGateway() Gets the actor gateway that can be used to send messages to the TaskManager.
TaskManagerGateway	LogicalSlot.getTaskManagerGateway() Return the TaskManager gateway to talk to the TaskManager.

Uses of TaskManagerGateway in org.apache.flink.runtime.jobmaster.slotpool

Methods in org.apache.flink.runtime.jobmaster.slotpool that return TaskManagerGateway

Modifier and Type	Method and Description
TaskManagerGateway	SingleLogicalSlot.getTaskManagerGateway()

Methods in org.apache.flink.runtime.jobmaster.slotpool with parameters of type TaskManagerGateway

Modifier and Type	Method and Description
Collection<SlotOffer>	SlotPoolImpl.offerSlots(TaskManagerLocation taskManagerLocation, TaskManagerGateway taskManagerGateway, Collection<SlotOffer> offers)
Collection<SlotOffer>	SlotPool.offerSlots(TaskManagerLocation taskManagerLocation, TaskManagerGateway taskManagerGateway, Collection<SlotOffer> offers) Offers multiple slots to the SlotPool.