Class OrderedMuxExchange

All Implemented Interfaces:
Iterable<PhysicalOperator>, GraphValue<PhysicalOperator>, Exchange, PhysicalOperator

public class OrderedMuxExchange extends AbstractMuxExchange
OrderedMuxExchange is a version of MuxExchange where the incoming batches are sorted merge operation is performed to produced a sorted stream as output.
  • Constructor Details

  • Method Details

    • getReceiver

      public Receiver getReceiver(int minorFragmentId)
      Description copied from interface: Exchange
      Get the Receiver associated with the given minorFragmentId. Cannot be called until after setupSenders() and setupReceivers() have been called.
      minorFragmentId - The minor fragment id, must be in the range [0, fragment.width).
      The materialized recevier for the given arguments.
    • getNewWithChild

      protected PhysicalOperator getNewWithChild(PhysicalOperator child)
      Specified by:
      getNewWithChild in class AbstractSingle