Class OperatorOrderingUtils


  • public class OperatorOrderingUtils
    extends Object
    • Constructor Detail

      • OperatorOrderingUtils

        public OperatorOrderingUtils()
    • Method Detail

      • isLopRoot

        public static boolean isLopRoot​(Lop lop)
      • isPersistableSparkOp

        public static boolean isPersistableSparkOp​(Lop lop)
      • isCollectForBroadcast

        public static boolean isCollectForBroadcast​(Lop lop)
      • markSharedSparkOps

        public static void markSharedSparkOps​(HashSet<Lop> sparkRoots,
                                              Map<Long,​Integer> operatorJobCount)