Class DefaultParallelismPass

  • All Implemented Interfaces:

    public final class DefaultParallelismPass
    extends AnnotatingPass
    Optimization pass for tagging parallelism execution property.
    • Constructor Detail

      • DefaultParallelismPass

        public DefaultParallelismPass()
        Default constructor with desired number of source parallelism 1, shuffle decreasing factor 2.
      • DefaultParallelismPass

        public DefaultParallelismPass​(int desiredSourceParallelism,
                                      int shuffleDecreaseFactor)
        Default constructor.
        desiredSourceParallelism - the desired number of source parallelism.
        shuffleDecreaseFactor - the parallelism decrease factor for shuffle edge.