Package org.apache.drill.exec.physical.base

Interface Sender

All Superinterfaces:

FragmentLeaf, FragmentRoot, GraphValue<PhysicalOperator>, Iterable<PhysicalOperator>, PhysicalOperator

All Known Implementing Classes:

AbstractSender, BroadcastSender, HashPartitionSender, OrderedPartitionSender, RangePartitionSender, SingleSender

public interface Sender
extends FragmentRoot

A sender is one half of an exchange node operations. It is responsible for subdividing/cloning and sending a local record set to a set of destination locations. This is typically only utilized at the level of the execution plan.

Method Summary

Modifier and Type	Method	Description
List<MinorFragmentEndpoint>	getDestinations()	Get the list of destination endpoints that this Sender will be communicating with.
int	getOppositeMajorFragmentId()	Get the receiver major fragment id that is opposite this sender.

Methods inherited from interface org.apache.drill.common.graph.GraphValue

accept

Methods inherited from interface java.lang.Iterable

forEach, iterator, spliterator

Methods inherited from interface org.apache.drill.exec.physical.base.PhysicalOperator

accept, getCost, getInitialAllocation, getMaxAllocation, getNewWithChildren, getOperatorId, getOperatorType, getSVMode, getUserName, isBufferedOperator, isExecutable, setCost, setMaxAllocation, setOperatorId

Method Details

getDestinations

List<MinorFragmentEndpoint> getDestinations()

Get the list of destination endpoints that this Sender will be communicating with.

Returns:

List of receiver MinorFragmentEndpoints each containing receiver fragment MinorFragmentId and endpoint where it is running.

getOppositeMajorFragmentId

int getOppositeMajorFragmentId()

Get the receiver major fragment id that is opposite this sender.

Returns:

The receiver major fragment id that is opposite this sender.