public class OrderedPartitionExchange extends AbstractExchange
Exchange.ParallelizationDependency
receiverLocations, receiverMajorFragmentId, senderLocations, senderMajorFragmentId
child
INIT_ALLOCATION, initialAllocation, MAX_ALLOCATION, maxAllocation, userName
Constructor and Description |
---|
OrderedPartitionExchange(List<Order.Ordering> orderings,
FieldReference ref,
PhysicalOperator child,
Integer recordsToSample,
Integer samplingFactor,
Float completionFactor) |
Modifier and Type | Method and Description |
---|---|
protected PhysicalOperator |
getNewWithChild(PhysicalOperator child) |
Receiver |
getReceiver(int minorFragmentId)
Get the Receiver associated with the given minorFragmentId.
|
Sender |
getSender(int minorFragmentId,
PhysicalOperator child)
Get the Sender associated with the given minorFragmentId.
|
accept, getDefaultAffinityMap, getOperatorType, getParallelizationDependency, getReceiverMemory, getReceiverParallelizationInfo, getSenderMemory, getSenderParallelizationInfo, isExecutable, setupReceivers, setupReceivers, setupSenders, setupSenders
getChild, getNewWithChildren, iterator
accept, getCost, getInitialAllocation, getMaxAllocation, getOperatorId, getSVMode, getUserName, isBufferedOperator, setCost, setMaxAllocation, setOperatorId
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getCost, getInitialAllocation, getMaxAllocation, getNewWithChildren, getOperatorId, getSVMode, getUserName, isBufferedOperator, setCost, setMaxAllocation, setOperatorId
accept
forEach, iterator, spliterator
public OrderedPartitionExchange(List<Order.Ordering> orderings, FieldReference ref, PhysicalOperator child, Integer recordsToSample, Integer samplingFactor, Float completionFactor)
public Sender getSender(int minorFragmentId, PhysicalOperator child)
Exchange
minorFragmentId
- The minor fragment id, must be in the range [0, fragment.width).child
- The feeding node for the requested sender.public Receiver getReceiver(int minorFragmentId)
Exchange
minorFragmentId
- The minor fragment id, must be in the range [0, fragment.width).protected PhysicalOperator getNewWithChild(PhysicalOperator child)
getNewWithChild
in class AbstractSingle
Copyright © 1970 The Apache Software Foundation. All rights reserved.