public class UnorderedDeMuxExchange extends AbstractDeMuxExchange
Exchange.ParallelizationDependency
expr, receiverToSenderMapping, senderToReceiversMapping
receiverLocations, receiverMajorFragmentId, senderLocations, senderMajorFragmentId
child
INIT_ALLOCATION, initialAllocation, MAX_ALLOCATION, maxAllocation, userName
Constructor and Description |
---|
UnorderedDeMuxExchange(PhysicalOperator child,
LogicalExpression expr) |
Modifier and Type | Method and Description |
---|---|
protected PhysicalOperator |
getNewWithChild(PhysicalOperator child) |
Receiver |
getReceiver(int minorFragmentId)
Get the Receiver associated with the given minorFragmentId.
|
createSenderReceiverMapping, getExpression, getParallelizationDependency, getReceiverParallelizationInfo, getSender, getSenderParallelizationInfo
accept, getDefaultAffinityMap, getOperatorType, getReceiverMemory, getSenderMemory, 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 UnorderedDeMuxExchange(PhysicalOperator child, LogicalExpression expr)
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.