Package | Description |
---|---|
org.apache.flink.runtime.deployment | |
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.instance | |
org.apache.flink.runtime.jobmanager.scheduler |
Modifier and Type | Method and Description |
---|---|
static InputChannelDeploymentDescriptor[] |
InputChannelDeploymentDescriptor.fromEdges(ExecutionEdge[] edges,
SimpleSlot consumerSlot,
boolean allowLazyDeployment)
Creates an input channel deployment descriptor for each partition.
|
Modifier and Type | Field and Description |
---|---|
Future<SimpleSlot> |
ExecutionAndSlot.slotFuture |
Modifier and Type | Method and Description |
---|---|
SimpleSlot |
Execution.getAssignedResource() |
SimpleSlot |
ExecutionVertex.getCurrentAssignedResource() |
Modifier and Type | Method and Description |
---|---|
Future<SimpleSlot> |
Execution.allocateSlotForExecution(SlotProvider slotProvider,
boolean queued) |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionVertex.deployToSlot(SimpleSlot slot) |
void |
Execution.deployToSlot(SimpleSlot slot) |
Modifier and Type | Method and Description |
---|---|
static void |
ExecutionGraphUtils.releaseSlotFuture(Future<SimpleSlot> slotFuture)
Releases the slot represented by the given future.
|
Constructor and Description |
---|
ExecutionAndSlot(Execution executionAttempt,
Future<SimpleSlot> slotFuture) |
Modifier and Type | Method and Description |
---|---|
SimpleSlot |
SlotSharingGroupAssignment.addSharedSlotAndAllocateSubSlot(SharedSlot sharedSlot,
Locality locality,
CoLocationConstraint constraint) |
SimpleSlot |
SlotSharingGroupAssignment.addSharedSlotAndAllocateSubSlot(SharedSlot sharedSlot,
Locality locality,
JobVertexID groupId) |
SimpleSlot |
Instance.allocateSimpleSlot(JobID jobID)
Allocates a simple slot on this TaskManager instance.
|
SimpleSlot |
SlotSharingGroupAssignment.getSlotForTask(ExecutionVertex vertex)
Gets a slot suitable for the given task vertex.
|
SimpleSlot |
SlotSharingGroupAssignment.getSlotForTask(ExecutionVertex vertex,
CoLocationConstraint constraint)
Gets a slot for a task that has a co-location constraint.
|
Modifier and Type | Method and Description |
---|---|
Future<SimpleSlot> |
SlotProvider.allocateSlot(ScheduledUnit task,
boolean allowQueued)
Allocating slot with specific requirement.
|
Future<SimpleSlot> |
SlotPool.allocateSlot(ScheduledUnit task,
ResourceProfile resources,
Iterable<TaskManagerLocation> locationPreferences) |
Future<SimpleSlot> |
SlotPoolGateway.allocateSlot(ScheduledUnit task,
ResourceProfile resources,
Iterable<TaskManagerLocation> locationPreferences,
Time timeout) |
Modifier and Type | Method and Description |
---|---|
protected SimpleSlot |
Scheduler.getFreeSlotForTask(ExecutionVertex vertex,
Iterable<TaskManagerLocation> requestedLocations,
boolean localOnly)
Gets a suitable instance to schedule the vertex execution to.
|
protected SimpleSlot |
Scheduler.getNewSlotForSharingGroup(ExecutionVertex vertex,
Iterable<TaskManagerLocation> 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 |
---|---|
Future<SimpleSlot> |
Scheduler.allocateSlot(ScheduledUnit task,
boolean allowQueued) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.