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

Class AbstractReceiver

java.lang.Object

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

org.apache.drill.exec.physical.base.AbstractReceiver

All Implemented Interfaces:

Iterable<PhysicalOperator>, GraphValue<PhysicalOperator>, FragmentLeaf, PhysicalOperator, Receiver

Direct Known Subclasses:

MergingReceiverPOP, UnorderedReceiver

public abstract class AbstractReceiver
extends AbstractBase
implements Receiver

Field Summary

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

INIT_ALLOCATION, initialAllocation, MAX_ALLOCATION, maxAllocation, userName

Constructor Summary

Constructors

Constructor	Description
AbstractReceiver(int oppositeMajorFragmentId, List<MinorFragmentEndpoint> senders, boolean spooling)

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.
final PhysicalOperator	getNewWithChildren(List<PhysicalOperator> children)	Regenerate with this node with a new set of children.
int	getNumSenders()
int	getOppositeMajorFragmentId()
List<MinorFragmentEndpoint>	getProvidingEndpoints()	A receiver is expecting streams from one or more providing endpoints.
boolean	isSpooling()
Iterator<PhysicalOperator>	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, spliterator

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

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

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

supportsOutOfOrderExchange

Constructor Details

AbstractReceiver

public AbstractReceiver(int oppositeMajorFragmentId,
 List<MinorFragmentEndpoint> senders,
 boolean spooling)

Parameters:

oppositeMajorFragmentId - MajorFragmentId of fragments that are sending data to this receiver.

senders - List of sender MinorFragmentEndpoints each containing sender MinorFragmentId and Drillbit endpoint where it is running.

Method Details

iterator

public Iterator<PhysicalOperator> iterator()

Specified by:

iterator in interface Iterable<PhysicalOperator>

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

getNewWithChildren

public final PhysicalOperator getNewWithChildren(List<PhysicalOperator> children)

Description copied from interface: PhysicalOperator

Regenerate with this node with a new set of children. This is used in the case of materialization or optimization.

Specified by:

getNewWithChildren in interface PhysicalOperator

Parameters:

children -

getOppositeMajorFragmentId

public int getOppositeMajorFragmentId()

Specified by:

getOppositeMajorFragmentId in interface Receiver

getProvidingEndpoints

public List<MinorFragmentEndpoint> getProvidingEndpoints()

Description copied from interface: Receiver

A receiver is expecting streams from one or more providing endpoints.

Specified by:

getProvidingEndpoints in interface Receiver

Returns:

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

getNumSenders

public int getNumSenders()

isSpooling

public boolean isSpooling()

Specified by:

isSpooling in interface Receiver