Class OrderedPartitionExchange
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.OrderedPartitionExchange
- All Implemented Interfaces:
Iterable<PhysicalOperator>
,GraphValue<PhysicalOperator>
,Exchange
,PhysicalOperator
-
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, userName
-
Constructor Summary
ConstructorDescriptionOrderedPartitionExchange
(List<Order.Ordering> orderings, FieldReference ref, PhysicalOperator child, Integer recordsToSample, Integer samplingFactor, Float completionFactor) -
Method Summary
Modifier and TypeMethodDescriptionprotected PhysicalOperator
getNewWithChild
(PhysicalOperator child) getReceiver
(int minorFragmentId) Get the Receiver associated with the given minorFragmentId.getSender
(int minorFragmentId, PhysicalOperator child) Get the Sender associated with the given minorFragmentId.Methods inherited from class org.apache.drill.exec.physical.base.AbstractExchange
accept, getDefaultAffinityMap, getOperatorType, getParallelizationDependency, getReceiverMemory, getReceiverParallelizationInfo, getSenderMemory, getSenderParallelizationInfo, 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.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
-
OrderedPartitionExchange
public OrderedPartitionExchange(List<Order.Ordering> orderings, FieldReference ref, PhysicalOperator child, Integer recordsToSample, Integer samplingFactor, Float completionFactor)
-
-
Method Details
-
getSender
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
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
- Specified by:
getNewWithChild
in classAbstractSingle
-