Package | Description |
---|---|
org.apache.flink.runtime.executiongraph.failover.flip1 | |
org.apache.flink.runtime.scheduler.strategy |
Modifier and Type | Method and Description |
---|---|
static Set<Set<SchedulingExecutionVertex>> |
SchedulingPipelinedRegionComputeUtil.computePipelinedRegions(Iterable<? extends SchedulingExecutionVertex> topologicallySortedVertices,
java.util.function.Function<ExecutionVertexID,? extends SchedulingExecutionVertex> executionVertexRetriever,
java.util.function.Function<IntermediateResultPartitionID,? extends SchedulingResultPartition> resultPartitionRetriever) |
Modifier and Type | Method and Description |
---|---|
static Set<Set<SchedulingExecutionVertex>> |
SchedulingPipelinedRegionComputeUtil.computePipelinedRegions(Iterable<? extends SchedulingExecutionVertex> topologicallySortedVertices,
java.util.function.Function<ExecutionVertexID,? extends SchedulingExecutionVertex> executionVertexRetriever,
java.util.function.Function<IntermediateResultPartitionID,? extends SchedulingResultPartition> resultPartitionRetriever) |
static Set<Set<SchedulingExecutionVertex>> |
SchedulingPipelinedRegionComputeUtil.computePipelinedRegions(Iterable<? extends SchedulingExecutionVertex> topologicallySortedVertices,
java.util.function.Function<ExecutionVertexID,? extends SchedulingExecutionVertex> executionVertexRetriever,
java.util.function.Function<IntermediateResultPartitionID,? extends SchedulingResultPartition> resultPartitionRetriever) |
Modifier and Type | Method and Description |
---|---|
SchedulingExecutionVertex |
SchedulingTopology.getVertex(ExecutionVertexID executionVertexId)
Looks up the
SchedulingExecutionVertex for the given ExecutionVertexID . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.