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 and Description
AbstractReceiver(int oppositeMajorFragmentId, List<MinorFragmentEndpoint> senders, boolean spooling)

Method Summary

Modifier and Type	Method and 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.
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.exec.physical.base.Receiver

supportsOutOfOrderExchange

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.common.graph.GraphValue

accept

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

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 Detail

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 extends Throwable

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

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

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