Package | Description |
---|---|
org.apache.flink.runtime.instance | |
org.apache.flink.runtime.jobmanager.slots |
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
InstanceID |
InstanceManager.registerTaskManager(TaskManagerGateway taskManagerGateway,
TaskManagerLocation taskManagerLocation,
HardwareDescription resources,
int numberOfSlots)
Registers a task manager.
|
Constructor and Description |
---|
Instance(TaskManagerGateway taskManagerGateway,
TaskManagerLocation location,
InstanceID id,
HardwareDescription resources,
int numberOfSlots)
Constructs an instance reflecting a registered TaskManager.
|
SharedSlot(JobID jobID,
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(JobID jobID,
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(JobID jobID,
SlotOwner owner,
TaskManagerLocation location,
int slotNumber,
TaskManagerGateway taskManagerGateway)
Creates a new simple slot that stands alone and does not belong to shared slot.
|
SimpleSlot(JobID jobID,
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.
|
Slot(JobID jobID,
SlotOwner owner,
TaskManagerLocation location,
int slotNumber,
TaskManagerGateway taskManagerGateway,
SharedSlot parent,
AbstractID groupID)
Base constructor for slots.
|
Modifier and Type | Class and Description |
---|---|
class |
ActorTaskManagerGateway
Implementation of the
TaskManagerGateway for ActorGateway . |
Modifier and Type | Method and Description |
---|---|
TaskManagerGateway |
AllocatedSlot.getTaskManagerGateway()
Gets the actor gateway that can be used to send messages to the TaskManager.
|
Constructor and Description |
---|
AllocatedSlot(AllocationID slotAllocationId,
JobID jobID,
TaskManagerLocation location,
int slotNumber,
ResourceProfile resourceProfile,
TaskManagerGateway taskManagerGateway) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.