Uses of Interface
org.apache.drill.exec.physical.base.Exchange
Packages that use Exchange
Package
Description
-
Uses of Exchange in org.apache.drill.exec.physical.base
Classes in org.apache.drill.exec.physical.base that implement ExchangeMethods in org.apache.drill.exec.physical.base with parameters of type ExchangeModifier and TypeMethodDescriptionAbstractPhysicalVisitor.visitExchange
(Exchange exchange, X value) PhysicalVisitor.visitExchange
(Exchange exchange, EXTRA value) -
Uses of Exchange in org.apache.drill.exec.physical.config
Classes in org.apache.drill.exec.physical.config that implement ExchangeModifier and TypeClassDescriptionclass
DeMuxExchange is opposite of MuxExchange.class
Multiplexing Exchange (MuxExchange) is used when results from multiple minor fragments belonging to the same major fragment running on a node need to be collected at one fragment on the same node before distributing the results further.class
class
class
class
OrderedMuxExchange is a version of MuxExchange where the incoming batches are sorted merge operation is performed to produced a sorted stream as output.class
class
class
class
class
UnorderedDeMuxExchange is a version of DeMuxExchange where the incoming batches are not sorted.class
UnorderedMuxExchange is a version of MuxExchange where the incoming batches are not sorted. -
Uses of Exchange in org.apache.drill.exec.planner
Methods in org.apache.drill.exec.planner with parameters of type ExchangeModifier and TypeMethodDescriptionfinal RET
AbstractOpWrapperVisitor.visitExchange
(Exchange exchange, Wrapper wrapper) AbstractOpWrapperVisitor.visitReceivingExchange
(Exchange exchange, Wrapper wrapper) AbstractOpWrapperVisitor.visitSendingExchange
(Exchange exchange, Wrapper wrapper) -
Uses of Exchange in org.apache.drill.exec.planner.fragment
Methods in org.apache.drill.exec.planner.fragment that return ExchangeModifier and TypeMethodDescriptionFragment.ExchangeFragmentPair.getExchange()
Fragment.getSendingExchange()
Methods in org.apache.drill.exec.planner.fragment with parameters of type ExchangeModifier and TypeMethodDescriptionvoid
Fragment.addReceiveExchange
(Exchange e, Fragment fragment) void
Fragment.addSendExchange
(Exchange e, Fragment sendingToFragment) MakeFragmentsVisitor.visitExchange
(Exchange exchange, Fragment receivingFragment) Materializer.visitExchange
(Exchange exchange, Materializer.IndexedFragmentNode iNode) MemoryCalculator.visitReceivingExchange
(Exchange exchange, Wrapper fragment) StatsCollector.visitReceivingExchange
(Exchange exchange, Wrapper wrapper) MemoryCalculator.visitSendingExchange
(Exchange exchange, Wrapper fragment) StatsCollector.visitSendingExchange
(Exchange exchange, Wrapper wrapper) Constructors in org.apache.drill.exec.planner.fragment with parameters of type Exchange -
Uses of Exchange in org.apache.drill.exec.planner.fragment.contrib
Methods in org.apache.drill.exec.planner.fragment.contrib with parameters of type ExchangeModifier and TypeMethodDescriptionExchangeRemoverMaterializer.visitExchange
(Exchange exchange, Materializer.IndexedFragmentNode iNode)