public class UnionExchange extends AbstractExchange
Exchange.ParallelizationDependency
receiverLocations, receiverMajorFragmentId, senderLocations, senderMajorFragmentId
child
INIT_ALLOCATION, initialAllocation, MAX_ALLOCATION, maxAllocation, userName
Constructor and Description |
---|
UnionExchange(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.
|
ParallelizationInfo |
getReceiverParallelizationInfo(List<CoordinationProtos.DrillbitEndpoint> senderFragmentEndpoints)
Default receiver parallelization width range is [1, Integer.MAX_VALUE] and affinity to nodes where sender
fragments are running.
|
Sender |
getSender(int minorFragmentId,
PhysicalOperator child)
Get the Sender associated with the given minorFragmentId.
|
protected void |
setupReceivers(List<CoordinationProtos.DrillbitEndpoint> receiverLocations) |
void |
setupSenders(List<CoordinationProtos.DrillbitEndpoint> senderLocations) |
accept, getDefaultAffinityMap, getOperatorType, getParallelizationDependency, getReceiverMemory, getSenderMemory, getSenderParallelizationInfo, isExecutable, setupReceivers, 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 UnionExchange(PhysicalOperator child)
public ParallelizationInfo getReceiverParallelizationInfo(List<CoordinationProtos.DrillbitEndpoint> senderFragmentEndpoints)
AbstractExchange
getReceiverParallelizationInfo
in interface Exchange
getReceiverParallelizationInfo
in class AbstractExchange
senderFragmentEndpoints
- Endpoints assigned to receiver fragment if available, otherwise an empty list.ParallelizationInfo
.public void setupSenders(List<CoordinationProtos.DrillbitEndpoint> senderLocations)
setupSenders
in class AbstractExchange
protected void setupReceivers(List<CoordinationProtos.DrillbitEndpoint> receiverLocations) throws PhysicalOperatorSetupException
setupReceivers
in class AbstractExchange
PhysicalOperatorSetupException
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.