Package | Description |
---|---|
org.apache.flink.runtime.scheduler.adapter | |
org.apache.flink.runtime.scheduler.strategy |
Modifier and Type | Method and Description |
---|---|
Optional<SchedulingResultPartition> |
ExecutionGraphToSchedulingTopologyAdapter.getResultPartition(IntermediateResultPartitionID intermediateResultPartitionId) |
Modifier and Type | Method and Description |
---|---|
default SchedulingResultPartition |
SchedulingTopology.getResultPartitionOrThrow(IntermediateResultPartitionID intermediateResultPartitionId)
Looks up the
SchedulingResultPartition for the given IntermediateResultPartitionID . |
Modifier and Type | Method and Description |
---|---|
Collection<SchedulingResultPartition> |
SchedulingExecutionVertex.getConsumedResultPartitions()
Get all consumed result partitions.
|
Collection<SchedulingResultPartition> |
SchedulingExecutionVertex.getProducedResultPartitions()
Get all produced result partitions.
|
Optional<SchedulingResultPartition> |
SchedulingTopology.getResultPartition(IntermediateResultPartitionID intermediateResultPartitionId)
Looks up the
SchedulingResultPartition for the given IntermediateResultPartitionID . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.