org.apache.drill.exec.physical.config

Class UnionExchange

java.lang.Object

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

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

org.apache.drill.exec.physical.base.AbstractExchange

org.apache.drill.exec.physical.config.UnionExchange

All Implemented Interfaces:

Iterable<PhysicalOperator>, GraphValue<PhysicalOperator>, Exchange, PhysicalOperator

public class UnionExchange
extends AbstractExchange

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.drill.exec.physical.base.Exchange

Exchange.ParallelizationDependency

Field Summary

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

receiverLocations, receiverMajorFragmentId, senderLocations, senderMajorFragmentId

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

Constructor Summary

Constructors

Constructor and Description
UnionExchange(PhysicalOperator child)

Method Summary

Modifier and Type	Method and Description
protected PhysicalOperator	getNewWithChild(PhysicalOperator child)
Receiver	getReceiver(int minorFragmentId) Get the Receiver associated with the given minorFragmentId.
ParallelizationInfo	getReceiverParallelizationInfo(List<CoordinationProtos.DrillbitEndpoint> senderFragmentEndpoints) Default receiver parallelization width range is [1, Integer.MAX_VALUE] and affinity to nodes where sender fragments are running.
Sender	getSender(int minorFragmentId, PhysicalOperator child) Get the Sender associated with the given minorFragmentId.
protected void	setupReceivers(List<CoordinationProtos.DrillbitEndpoint> receiverLocations)
void	setupSenders(List<CoordinationProtos.DrillbitEndpoint> senderLocations)

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

accept, getDefaultAffinityMap, getOperatorType, getParallelizationDependency, getReceiverMemory, getSenderMemory, getSenderParallelizationInfo, isExecutable, setupReceivers, setupSenders

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

getChild, getNewWithChildren, iterator

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

accept, getCost, getInitialAllocation, getMaxAllocation, getOperatorId, getSVMode, getUserName, isBufferedOperator, 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.Exchange

getChild

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

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

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

accept

Methods inherited from interface java.lang.Iterable

forEach, iterator, spliterator

Constructor Detail

UnionExchange

public UnionExchange(PhysicalOperator child)

Method Detail

getReceiverParallelizationInfo

public ParallelizationInfo getReceiverParallelizationInfo(List<CoordinationProtos.DrillbitEndpoint> senderFragmentEndpoints)

Description copied from class: AbstractExchange

Default receiver parallelization width range is [1, Integer.MAX_VALUE] and affinity to nodes where sender fragments are running.

Specified by:

getReceiverParallelizationInfo in interface Exchange

Overrides:

getReceiverParallelizationInfo in class AbstractExchange

Parameters:

senderFragmentEndpoints - Endpoints assigned to receiver fragment if available, otherwise an empty list.

Returns:

Receiver ParallelizationInfo.

setupSenders

public void setupSenders(List<CoordinationProtos.DrillbitEndpoint> senderLocations)

Overrides:

setupSenders in class AbstractExchange

setupReceivers

protected void setupReceivers(List<CoordinationProtos.DrillbitEndpoint> receiverLocations)
                       throws PhysicalOperatorSetupException

Overrides:

setupReceivers in class AbstractExchange

Throws:

PhysicalOperatorSetupException

getSender

public Sender getSender(int minorFragmentId,
                        PhysicalOperator child)

Description copied from interface: Exchange

Get the Sender associated with the given minorFragmentId. Cannot be called until after setupSenders() and setupReceivers() have been called.

Parameters:

minorFragmentId - The minor fragment id, must be in the range [0, fragment.width).

child - The feeding node for the requested sender.

Returns:

The materialized sender for the given arguments.

getReceiver

public Receiver getReceiver(int minorFragmentId)

Description copied from interface: Exchange

Get the Receiver associated with the given minorFragmentId. Cannot be called until after setupSenders() and setupReceivers() have been called.

Parameters:

minorFragmentId - The minor fragment id, must be in the range [0, fragment.width).

Returns:

The materialized recevier for the given arguments.

getNewWithChild

protected PhysicalOperator getNewWithChild(PhysicalOperator child)

Specified by:

getNewWithChild in class AbstractSingle