org.apache.flink.runtime.jobgraph.forwardgroup

Class ForwardGroup

java.lang.Object

org.apache.flink.runtime.jobgraph.forwardgroup.ForwardGroup

public class ForwardGroup
extends Object

A forward group is a set of job vertices connected via forward edges. Parallelisms of all job vertices in the same ForwardGroup must be the same.

Constructor Summary

Constructors

Constructor and Description
ForwardGroup(Set<JobVertex> jobVertices)

Method Summary

Modifier and Type	Method and Description
Set<JobVertexID>	getJobVertexIds()
int	getMaxParallelism()
int	getParallelism()
boolean	isMaxParallelismDecided()
boolean	isParallelismDecided()
void	setParallelism(int parallelism)
int	size()

Methods inherited from class java.lang.Object

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

Constructor Detail

ForwardGroup

public ForwardGroup(Set<JobVertex> jobVertices)

Method Detail

setParallelism

public void setParallelism(int parallelism)

isParallelismDecided

public boolean isParallelismDecided()

getParallelism

public int getParallelism()

isMaxParallelismDecided

public boolean isMaxParallelismDecided()

getMaxParallelism

public int getMaxParallelism()

size

public int size()

getJobVertexIds

public Set<JobVertexID> getJobVertexIds()