Class DefaultParallelismPass

  • All Implemented Interfaces:
    java.util.function.Function<IRDAG,​IRDAG>

    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.
        Parameters:
        desiredSourceParallelism - the desired number of source parallelism.
        shuffleDecreaseFactor - the parallelism decrease factor for shuffle edge.
    • Method Detail

      • equals

        public boolean equals​(java.lang.Object o)
        Overrides:
        equals in class java.lang.Object
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object