Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.instance | |
org.apache.flink.runtime.jobmanager.scheduler | |
org.apache.flink.runtime.messages |
This package contains the messages that are sent between actors, like the
JobManager and
TaskManager to coordinate the distributed operations. |
Modifier and Type | Method and Description |
---|---|
Iterable<Instance> |
ExecutionVertex.getPreferredLocations()
Gets the location preferences of this task, determined by the locations of the predecessors from which
it receives input data.
|
Modifier and Type | Method and Description |
---|---|
void |
ExecutionVertex.setLocationConstraintHosts(List<Instance> instances) |
Modifier and Type | Method and Description |
---|---|
Instance |
Slot.getInstance()
Gets the instance from which the slot was allocated.
|
Instance |
InstanceDiedException.getInstance() |
Instance |
InstanceManager.getRegisteredInstance(akka.actor.ActorRef ref) |
Instance |
InstanceManager.getRegisteredInstance(ResourceID ref) |
Instance |
InstanceManager.getRegisteredInstanceById(InstanceID instanceID) |
Modifier and Type | Method and Description |
---|---|
Collection<Instance> |
InstanceManager.getAllRegisteredInstances() |
Modifier and Type | Method and Description |
---|---|
void |
InstanceListener.instanceDied(Instance instance)
Called when an instance died.
|
void |
InstanceListener.newInstanceAvailable(Instance instance)
Called when a new instance becomes available.
|
Constructor and Description |
---|
InstanceDiedException(Instance instance) |
SharedSlot(JobID jobID,
Instance instance,
int slotNumber,
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,
Instance instance,
int slotNumber,
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,
Instance instance,
int slotNumber)
Creates a new simple slot that stands alone and does not belong to shared slot.
|
SimpleSlot(JobID jobID,
Instance instance,
int slotNumber,
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,
Instance instance,
int slotNumber,
SharedSlot parent,
AbstractID groupID)
Base constructor for slots.
|
Modifier and Type | Method and Description |
---|---|
Instance |
CoLocationConstraint.getLocation()
Gets the location assigned to this slot.
|
Modifier and Type | Method and Description |
---|---|
Map<String,List<Instance>> |
Scheduler.getInstancesByHost() |
Modifier and Type | Method and Description |
---|---|
void |
Scheduler.instanceDied(Instance instance) |
void |
Scheduler.newInstanceAvailable(Instance instance) |
void |
SlotAvailabilityListener.newSlotAvailable(Instance instance) |
void |
Scheduler.newSlotAvailable(Instance instance) |
Modifier and Type | Method and Description |
---|---|
protected SimpleSlot |
Scheduler.getFreeSlotForTask(ExecutionVertex vertex,
Iterable<Instance> requestedLocations,
boolean localOnly)
Gets a suitable instance to schedule the vertex execution to.
|
protected SimpleSlot |
Scheduler.getNewSlotForSharingGroup(ExecutionVertex vertex,
Iterable<Instance> requestedLocations,
SlotSharingGroupAssignment groupAssignment,
CoLocationConstraint constraint,
boolean localOnly)
Tries to allocate a new slot for a vertex that is part of a slot sharing group.
|
Modifier and Type | Method and Description |
---|---|
Collection<Instance> |
JobManagerMessages.RegisteredTaskManagers.asJavaCollection() |
Iterable<Instance> |
JobManagerMessages.RegisteredTaskManagers.asJavaIterable() |
scala.Option<Instance> |
JobManagerMessages.TaskManagerInstance.instance() |
scala.collection.Iterable<Instance> |
JobManagerMessages.RegisteredTaskManagers.taskManagers() |
Constructor and Description |
---|
RegisteredTaskManagers(scala.collection.Iterable<Instance> taskManagers) |
TaskManagerInstance(scala.Option<Instance> instance) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.