| Package | Description |
|---|---|
| org.apache.drill.exec.physical.base | |
| org.apache.drill.exec.physical.impl.partitionsender |
| Modifier and Type | Method and Description |
|---|---|
RETURN |
PhysicalVisitor.visitHashPartitionSender(HashPartitionSender op,
EXTRA value) |
T |
AbstractPhysicalVisitor.visitHashPartitionSender(HashPartitionSender op,
X value) |
| Modifier and Type | Method and Description |
|---|---|
RootExec |
PartitionSenderCreator.getRoot(ExecutorFragmentContext context,
HashPartitionSender config,
List<RecordBatch> children) |
protected PartitionerTemplate.OutgoingRecordBatch |
PartitionerTemplate.newOutgoingRecordBatch(OperatorStats stats,
HashPartitionSender operator,
AccountingDataTunnel tunnel,
FragmentContext context,
BufferAllocator allocator,
int oppositeMinorFragmentId)
Shim method to be overridden in plain-old Java mode by the subclass to instantiate the
generated inner class.
|
void |
PartitionerTemplate.setup(ExchangeFragmentContext context,
RecordBatch incoming,
HashPartitionSender popConfig,
OperatorStats stats,
OperatorContext oContext,
ClassGenerator<?> cg,
int start,
int end) |
void |
Partitioner.setup(ExchangeFragmentContext context,
RecordBatch incoming,
HashPartitionSender popConfig,
OperatorStats stats,
OperatorContext oContext,
ClassGenerator<?> cg,
int start,
int count) |
| Constructor and Description |
|---|
OutgoingRecordBatch(OperatorStats stats,
HashPartitionSender operator,
AccountingDataTunnel tunnel,
FragmentContext context,
BufferAllocator allocator,
int oppositeMinorFragmentId) |
PartitionSenderRootExec(RootFragmentContext context,
RecordBatch incoming,
HashPartitionSender operator) |
PartitionSenderRootExec(RootFragmentContext context,
RecordBatch incoming,
HashPartitionSender operator,
boolean closeIncoming) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.