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 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
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)