Package | Description |
---|---|
org.apache.flink.runtime.scheduler.adapter | |
org.apache.flink.runtime.scheduler.strategy |
Modifier and Type | Method and Description |
---|---|
Optional<SchedulingExecutionVertex> |
ExecutionGraphToSchedulingTopologyAdapter.getVertex(ExecutionVertexID executionVertexId) |
Iterable<SchedulingExecutionVertex> |
ExecutionGraphToSchedulingTopologyAdapter.getVertices() |
Modifier and Type | Method and Description |
---|---|
SchedulingExecutionVertex |
SchedulingResultPartition.getProducer()
Gets the producer of this result partition.
|
default SchedulingExecutionVertex |
SchedulingTopology.getVertexOrThrow(ExecutionVertexID executionVertexId)
Looks up the
SchedulingExecutionVertex for the given ExecutionVertexID . |
Modifier and Type | Method and Description |
---|---|
Collection<SchedulingExecutionVertex> |
SchedulingResultPartition.getConsumers()
Gets the consumers of this result partition.
|
Optional<SchedulingExecutionVertex> |
SchedulingTopology.getVertex(ExecutionVertexID executionVertexId)
Looks up the
SchedulingExecutionVertex for the given ExecutionVertexID . |
Iterable<SchedulingExecutionVertex> |
SchedulingTopology.getVertices()
Returns an iterable over all
SchedulingExecutionVertex in topological
sorted order. |
Modifier and Type | Method and Description |
---|---|
boolean |
InputDependencyConstraintChecker.check(SchedulingExecutionVertex schedulingExecutionVertex) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.