org.apache.flink.runtime.executiongraph

Class EdgeManagerBuildUtil

java.lang.Object

org.apache.flink.runtime.executiongraph.EdgeManagerBuildUtil

public class EdgeManagerBuildUtil
extends Object

Utilities for building EdgeManager.

Constructor Summary

Constructors

Constructor and Description
EdgeManagerBuildUtil()

Method Summary

Modifier and Type	Method and Description
static int	computeMaxEdgesToTargetExecutionVertex(int targetParallelism, int sourceParallelism, DistributionPattern distributionPattern) Given parallelisms of two job vertices, compute the max number of edges connected to a target execution vertex from the source execution vertices.

Methods inherited from class java.lang.Object

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

Constructor Detail

EdgeManagerBuildUtil

public EdgeManagerBuildUtil()

Method Detail

computeMaxEdgesToTargetExecutionVertex

public static int computeMaxEdgesToTargetExecutionVertex(int targetParallelism,
                                                         int sourceParallelism,
                                                         DistributionPattern distributionPattern)

Given parallelisms of two job vertices, compute the max number of edges connected to a target execution vertex from the source execution vertices. Note that edge is considered undirected here. It can be an edge connected from an upstream job vertex to a downstream job vertex, or in a reversed way.

Parameters:

targetParallelism - parallelism of the target job vertex.

sourceParallelism - parallelism of the source job vertex.

distributionPattern - the DistributionPattern of the connecting edge.