org.apache.drill.exec.physical.base

Interface Receiver

All Superinterfaces:

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

All Known Implementing Classes:

AbstractReceiver, MergingReceiverPOP, UnorderedReceiver

public interface Receiver
extends FragmentLeaf

A receiver is one half of an exchange operator. The receiver is responsible for taking in one or more streams from corresponding Senders. Receivers are a special type of Physical Operator that are typically only expressed within the execution plan.

Method Summary

Modifier and Type	Method and Description
int	getOppositeMajorFragmentId()
List<MinorFragmentEndpoint>	getProvidingEndpoints() A receiver is expecting streams from one or more providing endpoints.
boolean	isSpooling()
boolean	supportsOutOfOrderExchange() Whether or not this receive supports out of order exchange.

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

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

accept

Methods inherited from interface java.lang.Iterable

forEach, iterator, spliterator

Method Detail

getProvidingEndpoints

List<MinorFragmentEndpoint> getProvidingEndpoints()

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

Returns:

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

supportsOutOfOrderExchange

boolean supportsOutOfOrderExchange()

Whether or not this receive supports out of order exchange. This provides a hint for the scheduling node on whether the receiver can start work if only a subset of all sending endpoints are currently providing data. A random receiver would supports this form of operation. A NWAY receiver would not.

Returns:

True if this receiver supports working on a streaming/out of order input.

getOppositeMajorFragmentId

int getOppositeMajorFragmentId()

isSpooling

boolean isSpooling()