Class OperatorAttributes

    • Method Detail

      • isOutputOnlyAfterEndOfStream

        public boolean isOutputOnlyAfterEndOfStream()
        Returns true if and only if the operator only emits records after all its inputs have ended.

        Here are the implications when it is true:

        • The results of this operator as well as its chained operators have blocking partition type.
        • This operator as well as its chained operators will be executed in batch mode.
      • isInternalSorterSupported

        public boolean isInternalSorterSupported()
        Returns true iff the operator uses an internal sorter to sort inputs by key. When it is true, the input records will not to be sorted externally before being fed into this operator.