Class MergingReceiverPOP

All Implemented Interfaces:
Iterable<PhysicalOperator>, GraphValue<PhysicalOperator>, FragmentLeaf, PhysicalOperator, Receiver

public class MergingReceiverPOP extends AbstractReceiver
  • Field Details

  • Constructor Details

  • Method Details

    • supportsOutOfOrderExchange

      public boolean supportsOutOfOrderExchange()
      Description copied from interface: Receiver
      Whether or not this receive supports out of order exchange. This provides a hint for the scheduling node on whether the receiver can start work if only a subset of all sending endpoints are currently providing data. A random receiver would supports this form of operation. A NWAY receiver would not.
      Returns:
      True if this receiver supports working on a streaming/out of order input.
    • accept

      public <T, X, E extends Throwable> T accept(PhysicalVisitor<T,X,E> physicalVisitor, X value) throws E
      Description copied from interface: PhysicalOperator
      Provides capability to build a set of output based on traversing a query graph tree.
      Specified by:
      accept in interface PhysicalOperator
      Overrides:
      accept in class AbstractReceiver
      Throws:
      E extends Throwable
    • getOrderings

      public List<Order.Ordering> getOrderings()
    • getOperatorType

      public String getOperatorType()