| Package | Description |
|---|---|
| org.apache.drill.exec.physical.impl.mergereceiver | |
| org.apache.drill.exec.physical.impl.unorderedreceiver | |
| org.apache.drill.exec.work.batch |
| Constructor and Description |
|---|
MergingRecordBatch(ExchangeFragmentContext context,
MergingReceiverPOP config,
RawFragmentBatchProvider[] fragProviders) |
| Constructor and Description |
|---|
UnorderedReceiverBatch(ExchangeFragmentContext context,
RawFragmentBatchProvider fragProvider,
UnorderedReceiver config) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
RawBatchBuffer
A batch buffer is responsible for queuing incoming batches until a consumer is ready to receive them.
|
| Modifier and Type | Class and Description |
|---|---|
class |
BaseRawBatchBuffer<T> |
class |
SpoolingRawBatchBuffer
This implementation of RawBatchBuffer starts writing incoming batches to disk once the buffer size reaches a threshold.
|
class |
UnlimitedRawBatchBuffer |
Copyright © 2021 The Apache Software Foundation. All rights reserved.