Uses of Interface
org.apache.drill.exec.physical.base.Exchange
Package
Description
-
Uses of Exchange in org.apache.drill.exec.physical.base
Modifier and TypeMethodDescriptionAbstractPhysicalVisitor.visitExchange
(Exchange exchange, X value) PhysicalVisitor.visitExchange
(Exchange exchange, EXTRA value) -
Uses of Exchange in org.apache.drill.exec.physical.config
Modifier 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
Modifier 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
Modifier and TypeMethodDescriptionFragment.ExchangeFragmentPair.getExchange()
Fragment.getSendingExchange()
Modifier 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) -
Uses of Exchange in org.apache.drill.exec.planner.fragment.contrib
Modifier and TypeMethodDescriptionExchangeRemoverMaterializer.visitExchange
(Exchange exchange, Materializer.IndexedFragmentNode iNode)