Class 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 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()