Package org.apache.flink.runtime.jobgraph.forwardgroup

Class ForwardGroupComputeUtil

java.lang.Object

org.apache.flink.runtime.jobgraph.forwardgroup.ForwardGroupComputeUtil

public class ForwardGroupComputeUtil
extends Object

Common utils for computing forward groups.

Constructor Summary

Constructors

Constructor	Description
ForwardGroupComputeUtil()

Method Summary

Modifier and Type	Method	Description
static Map<JobVertexID,ForwardGroup>	computeForwardGroups(Iterable<JobVertex> topologicallySortedVertices, Function<JobVertex,Set<JobVertex>> forwardProducersRetriever)
static Map<JobVertexID,ForwardGroup>	computeForwardGroupsAndCheckParallelism(Iterable<JobVertex> topologicallySortedVertices)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ForwardGroupComputeUtil

public ForwardGroupComputeUtil()

Method Detail

computeForwardGroupsAndCheckParallelism

public static Map<JobVertexID,ForwardGroup> computeForwardGroupsAndCheckParallelism(Iterable<JobVertex> topologicallySortedVertices)

computeForwardGroups

public static Map<JobVertexID,ForwardGroup> computeForwardGroups(Iterable<JobVertex> topologicallySortedVertices,
                                                                       Function<JobVertex,Set<JobVertex>> forwardProducersRetriever)