Class AbstractSender

All Implemented Interfaces:
Iterable<PhysicalOperator>, GraphValue<PhysicalOperator>, FragmentLeaf, FragmentRoot, PhysicalOperator, Sender
Direct Known Subclasses:
BroadcastSender, HashPartitionSender, OrderedPartitionSender, RangePartitionSender, SingleSender

public abstract class AbstractSender extends AbstractSingle implements Sender
  • Field Details

    • oppositeMajorFragmentId

      protected final int oppositeMajorFragmentId
    • destinations

      protected final List<MinorFragmentEndpoint> destinations
  • Constructor Details

    • AbstractSender

      public AbstractSender(int oppositeMajorFragmentId, PhysicalOperator child, List<MinorFragmentEndpoint> destinations)
      Parameters:
      oppositeMajorFragmentId - MajorFragmentId of fragments that are receiving data sent by this sender.
      child - Child PhysicalOperator which is providing data to this Sender.
      destinations - List of receiver MinorFragmentEndpoints each containing MinorFragmentId and Drillbit endpoint where it is running.
  • Method Details

    • 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
      Throws:
      E extends Throwable
    • getOppositeMajorFragmentId

      public int getOppositeMajorFragmentId()
      Description copied from interface: Sender
      Get the receiver major fragment id that is opposite this sender.
      Specified by:
      getOppositeMajorFragmentId in interface Sender
      Returns:
      The receiver major fragment id that is opposite this sender.
    • getDestinations

      public List<MinorFragmentEndpoint> getDestinations()
      Description copied from interface: Sender
      Get the list of destination endpoints that this Sender will be communicating with.
      Specified by:
      getDestinations in interface Sender
      Returns:
      List of receiver MinorFragmentEndpoints each containing receiver fragment MinorFragmentId and endpoint where it is running.