Uses of Class
org.apache.drill.exec.physical.MinorFragmentEndpoint
-
Uses of MinorFragmentEndpoint in org.apache.drill.exec.physical.base
Modifier and TypeFieldDescriptionprotected final List<MinorFragmentEndpoint>
AbstractSender.destinations
Modifier and TypeMethodDescriptionAbstractSender.getDestinations()
Sender.getDestinations()
Get the list of destination endpoints that this Sender will be communicating with.static List<MinorFragmentEndpoint>
PhysicalOperatorUtil.getIndexOrderedEndpoints
(List<CoordinationProtos.DrillbitEndpoint> endpoints) Helper method to create a list ofMinorFragmentEndpoint
instances from a given endpoint assignment list.AbstractReceiver.getProvidingEndpoints()
Receiver.getProvidingEndpoints()
A receiver is expecting streams from one or more providing endpoints.ModifierConstructorDescriptionAbstractReceiver
(int oppositeMajorFragmentId, List<MinorFragmentEndpoint> senders, boolean spooling) AbstractSender
(int oppositeMajorFragmentId, PhysicalOperator child, List<MinorFragmentEndpoint> destinations) -
Uses of MinorFragmentEndpoint in org.apache.drill.exec.physical.config
Modifier and TypeFieldDescriptionprotected Map<Integer,
MinorFragmentEndpoint> AbstractDeMuxExchange.receiverToSenderMapping
protected org.apache.drill.shaded.guava.com.google.common.collect.ArrayListMultimap<Integer,
MinorFragmentEndpoint> AbstractMuxExchange.receiverToSenderMapping
protected Map<Integer,
MinorFragmentEndpoint> AbstractMuxExchange.senderToReceiverMapping
protected org.apache.drill.shaded.guava.com.google.common.collect.ArrayListMultimap<Integer,
MinorFragmentEndpoint> AbstractDeMuxExchange.senderToReceiversMapping
Modifier and TypeMethodDescriptionSingleSender.getDestinations()
protected final List<MinorFragmentEndpoint>
AbstractMuxExchange.getSenders
(int minorFragmentId) ModifierConstructorDescriptionBroadcastSender
(int oppositeMajorFragmentId, PhysicalOperator child, List<MinorFragmentEndpoint> destinations) HashPartitionSender
(int oppositeMajorFragmentId, PhysicalOperator child, LogicalExpression expr, List<MinorFragmentEndpoint> endpoints) HashPartitionSender
(int oppositeMajorFragmentId, PhysicalOperator child, LogicalExpression expr, List<MinorFragmentEndpoint> endpoints, int outgoingBatchSize) MergingReceiverPOP
(int oppositeMajorFragmentId, List<MinorFragmentEndpoint> senders, List<Order.Ordering> orderings, boolean spooling) RangePartitionSender
(int oppositeMajorFragmentId, PhysicalOperator child, List<MinorFragmentEndpoint> endpoints, PartitionFunction partitionFunction) UnorderedReceiver
(int oppositeMajorFragmentId, List<MinorFragmentEndpoint> senders, boolean spooling)