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

Class AbstractSender

java.lang.Object

org.apache.drill.exec.physical.base.AbstractBase

org.apache.drill.exec.physical.base.AbstractSingle

org.apache.drill.exec.physical.base.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 Summary

Fields

Modifier and Type	Field	Description
protected final List<MinorFragmentEndpoint>	destinations
protected final int	oppositeMajorFragmentId

Fields inherited from class org.apache.drill.exec.physical.base.AbstractSingle

child

Fields inherited from class org.apache.drill.exec.physical.base.AbstractBase

INIT_ALLOCATION, initialAllocation, MAX_ALLOCATION, maxAllocation, userName

Constructor Summary

Constructors

Constructor	Description
AbstractSender(int oppositeMajorFragmentId, PhysicalOperator child, List<MinorFragmentEndpoint> destinations)

Method Summary

Modifier and Type	Method	Description
<T, X, E extends Throwable> T	accept(PhysicalVisitor<T,X,E> physicalVisitor, X value)	Provides capability to build a set of output based on traversing a query graph tree.
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 class org.apache.drill.exec.physical.base.AbstractSingle

getChild, getNewWithChild, getNewWithChildren, iterator

Methods inherited from class org.apache.drill.exec.physical.base.AbstractBase

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

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

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

Parameters:

physicalVisitor -

Throws:

E

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.