public abstract class AbstractMuxExchange extends AbstractExchange
Exchange.ParallelizationDependency| Modifier and Type | Field and Description |
|---|---|
protected org.apache.drill.shaded.guava.com.google.common.collect.ArrayListMultimap<Integer,MinorFragmentEndpoint> |
receiverToSenderMapping |
protected Map<Integer,MinorFragmentEndpoint> |
senderToReceiverMapping |
receiverLocations, receiverMajorFragmentId, senderLocations, senderMajorFragmentIdchildINIT_ALLOCATION, initialAllocation, MAX_ALLOCATION, maxAllocation| Constructor and Description |
|---|
AbstractMuxExchange(PhysicalOperator child) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
createSenderReceiverMapping() |
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 List<MinorFragmentEndpoint> |
getSenders(int minorFragmentId) |
accept, getDefaultAffinityMap, getOperatorType, getParallelizationDependency, getReceiverMemory, getSenderMemory, getSenderParallelizationInfo, isExecutable, setupReceivers, setupReceivers, setupSenders, setupSendersgetChild, getNewWithChild, getNewWithChildren, iteratoraccept, getCost, getInitialAllocation, getMaxAllocation, getOperatorId, getSVMode, getUserName, isBufferedOperator, setCost, setMaxAllocation, setOperatorIdclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetChild, getReceivergetCost, getInitialAllocation, getMaxAllocation, getNewWithChildren, getOperatorId, getSVMode, getUserName, isBufferedOperator, setCost, setMaxAllocation, setOperatorIdacceptforEach, iterator, spliteratorprotected Map<Integer,MinorFragmentEndpoint> senderToReceiverMapping
protected org.apache.drill.shaded.guava.com.google.common.collect.ArrayListMultimap<Integer,MinorFragmentEndpoint> receiverToSenderMapping
public AbstractMuxExchange(PhysicalOperator child)
public ParallelizationInfo getReceiverParallelizationInfo(List<CoordinationProtos.DrillbitEndpoint> senderFragmentEndpoints)
AbstractExchangegetReceiverParallelizationInfo in interface ExchangegetReceiverParallelizationInfo in class AbstractExchangesenderFragmentEndpoints - Endpoints assigned to receiver fragment if available, otherwise an empty list.ParallelizationInfo.public Sender getSender(int minorFragmentId, PhysicalOperator child)
ExchangeminorFragmentId - The minor fragment id, must be in the range [0, fragment.width).child - The feeding node for the requested sender.protected final List<MinorFragmentEndpoint> getSenders(int minorFragmentId)
protected void createSenderReceiverMapping()
Copyright © 2021 The Apache Software Foundation. All rights reserved.