Class HashToMergeExchange

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

public class HashToMergeExchange extends AbstractExchange
  • Constructor Details

  • Method Details

    • getSender

      public Sender getSender(int minorFragmentId, PhysicalOperator child)
      Description copied from interface: Exchange
      Get the Sender 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).
      child - The feeding node for the requested sender.
      Returns:
      The materialized sender for the given arguments.
    • 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
    • getOrderExpressions

      public List<Order.Ordering> getOrderExpressions()