Uses of Class
org.apache.drill.exec.physical.MinorFragmentEndpoint
Packages that use MinorFragmentEndpoint
-
Uses of MinorFragmentEndpoint in org.apache.drill.exec.physical.base
Fields in org.apache.drill.exec.physical.base with type parameters of type MinorFragmentEndpointModifier and TypeFieldDescriptionprotected final List
<MinorFragmentEndpoint> AbstractSender.destinations
Methods in org.apache.drill.exec.physical.base that return types with arguments of type MinorFragmentEndpointModifier 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.Constructor parameters in org.apache.drill.exec.physical.base with type arguments of type MinorFragmentEndpointModifierConstructorDescriptionAbstractReceiver
(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
Fields in org.apache.drill.exec.physical.config with type parameters of type MinorFragmentEndpointModifier and TypeFieldDescriptionprotected Map
<Integer, MinorFragmentEndpoint> AbstractDeMuxExchange.receiverToSenderMapping
protected com.google.common.collect.ArrayListMultimap
<Integer, MinorFragmentEndpoint> AbstractMuxExchange.receiverToSenderMapping
protected Map
<Integer, MinorFragmentEndpoint> AbstractMuxExchange.senderToReceiverMapping
protected com.google.common.collect.ArrayListMultimap
<Integer, MinorFragmentEndpoint> AbstractDeMuxExchange.senderToReceiversMapping
Methods in org.apache.drill.exec.physical.config that return types with arguments of type MinorFragmentEndpointModifier and TypeMethodDescriptionSingleSender.getDestinations()
protected final List
<MinorFragmentEndpoint> AbstractMuxExchange.getSenders
(int minorFragmentId) Constructor parameters in org.apache.drill.exec.physical.config with type arguments of type MinorFragmentEndpointModifierConstructorDescriptionBroadcastSender
(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)