Class UnorderedDeMuxExchange

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

public class UnorderedDeMuxExchange extends AbstractDeMuxExchange
UnorderedDeMuxExchange is a version of DeMuxExchange where the incoming batches are not sorted.
  • 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.
      Parameters:
      minorFragmentId - The minor fragment id, must be in the range [0, fragment.width).
      Returns:
      The materialized recevier for the given arguments.
    • getNewWithChild

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