public final class SchedulingPipelinedRegionComputeUtil extends Object
SchedulingPipelinedRegion
s.Modifier and Type | Method and Description |
---|---|
static Set<Set<SchedulingExecutionVertex>> |
computePipelinedRegions(Iterable<? extends SchedulingExecutionVertex> topologicallySortedVertices,
java.util.function.Function<ExecutionVertexID,? extends SchedulingExecutionVertex> executionVertexRetriever,
java.util.function.Function<IntermediateResultPartitionID,? extends SchedulingResultPartition> resultPartitionRetriever) |
public static Set<Set<SchedulingExecutionVertex>> computePipelinedRegions(Iterable<? extends SchedulingExecutionVertex> topologicallySortedVertices, java.util.function.Function<ExecutionVertexID,? extends SchedulingExecutionVertex> executionVertexRetriever, java.util.function.Function<IntermediateResultPartitionID,? extends SchedulingResultPartition> resultPartitionRetriever)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.