Package org.apache.drill.exec.physical.config

Class UnorderedDeMuxExchange

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.AbstractDeMuxExchange

org.apache.drill.exec.physical.config.UnorderedDeMuxExchange

All Implemented Interfaces:

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

public class UnorderedDeMuxExchange
extends AbstractDeMuxExchange

UnorderedDeMuxExchange is a version of DeMuxExchange where the incoming batches are not sorted.

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.config.AbstractDeMuxExchange

expr, receiverToSenderMapping, senderToReceiversMapping

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, userName

Constructor Summary

Constructors

Constructor	Description
UnorderedDeMuxExchange(PhysicalOperator child, LogicalExpression expr)

Method Summary

Modifier and Type	Method	Description
protected PhysicalOperator	getNewWithChild(PhysicalOperator child)
Receiver	getReceiver(int minorFragmentId)	Get the Receiver associated with the given minorFragmentId.

Methods inherited from class org.apache.drill.exec.physical.config.AbstractDeMuxExchange

createSenderReceiverMapping, getExpression, getParallelizationDependency, getReceiverParallelizationInfo, getSender, getSenderParallelizationInfo

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

accept, getDefaultAffinityMap, getOperatorType, getReceiverMemory, getSenderMemory, isExecutable, setupReceivers, setupReceivers, setupSenders, 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.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, getSVMode, getUserName, isBufferedOperator, setCost, setMaxAllocation, setOperatorId

Constructor Details

UnorderedDeMuxExchange

public UnorderedDeMuxExchange(PhysicalOperator child,
 LogicalExpression expr)

Method Details

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