| Package | Description |
|---|---|
| org.apache.drill.exec.physical.base | |
| org.apache.drill.exec.physical.config | |
| org.apache.drill.exec.planner.fragment |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractReceiver |
| Modifier and Type | Method and Description |
|---|---|
Receiver |
Exchange.getReceiver(int minorFragmentId)
Get the Receiver associated with the given minorFragmentId.
|
| Modifier and Type | Method and Description |
|---|---|
RETURN |
PhysicalVisitor.visitReceiver(Receiver receiver,
EXTRA value) |
T |
AbstractPhysicalVisitor.visitReceiver(Receiver receiver,
X value) |
| Modifier and Type | Class and Description |
|---|---|
class |
MergingReceiverPOP |
class |
UnorderedReceiver |
| Modifier and Type | Method and Description |
|---|---|
Receiver |
RangePartitionExchange.getReceiver(int minorFragmentId) |
Receiver |
UnionExchange.getReceiver(int minorFragmentId) |
Receiver |
UnorderedMuxExchange.getReceiver(int minorFragmentId) |
Receiver |
SingleMergeExchange.getReceiver(int minorFragmentId) |
Receiver |
HashToMergeExchange.getReceiver(int minorFragmentId) |
Receiver |
HashToRandomExchange.getReceiver(int minorFragmentId) |
Receiver |
BroadcastExchange.getReceiver(int minorFragmentId) |
Receiver |
OrderedPartitionExchange.getReceiver(int minorFragmentId) |
Receiver |
OrderedMuxExchange.getReceiver(int minorFragmentId) |
Receiver |
UnorderedDeMuxExchange.getReceiver(int minorFragmentId) |
| Modifier and Type | Method and Description |
|---|---|
Void |
SimpleParallelizer.CountRequiredFragments.visitReceiver(Receiver receiver,
List<BitControl.Collector> collectors) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.