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.destinationsMethods 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 ofMinorFragmentEndpointinstances 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.receiverToSenderMappingprotected com.google.common.collect.ArrayListMultimap<Integer, MinorFragmentEndpoint> AbstractMuxExchange.receiverToSenderMappingprotected Map<Integer, MinorFragmentEndpoint> AbstractMuxExchange.senderToReceiverMappingprotected com.google.common.collect.ArrayListMultimap<Integer, MinorFragmentEndpoint> AbstractDeMuxExchange.senderToReceiversMappingMethods 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)