public class BroadcastExchange extends AbstractExchange
Exchange.ParallelizationDependency
receiverLocations, receiverMajorFragmentId, senderLocations, senderMajorFragmentId
child
INIT_ALLOCATION, initialAllocation, MAX_ALLOCATION, maxAllocation, userName
Constructor and Description |
---|
BroadcastExchange(PhysicalOperator child) |
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 BroadcastExchange(PhysicalOperator child)
protected PhysicalOperator getNewWithChild(PhysicalOperator child)
getNewWithChild
in class AbstractSingle
public Sender getSender(int minorFragmentId, PhysicalOperator child) throws PhysicalOperatorSetupException
Exchange
minorFragmentId
- The minor fragment id, must be in the range [0, fragment.width).child
- The feeding node for the requested sender.PhysicalOperatorSetupException
public Receiver getReceiver(int minorFragmentId)
Exchange
minorFragmentId
- The minor fragment id, must be in the range [0, fragment.width).Copyright © 1970 The Apache Software Foundation. All rights reserved.