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 sameForwardGroup
must be the same.
-
-
Constructor Summary
Constructors Constructor Description ForwardGroup(Set<JobVertex> jobVertices)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Set<JobVertexID>
getJobVertexIds()
int
getMaxParallelism()
int
getParallelism()
boolean
isMaxParallelismDecided()
boolean
isParallelismDecided()
void
setParallelism(int parallelism)
int
size()
-
-
-
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()
-
-