| Interface | Description |
|---|---|
| BaseRawBatchBuffer.BufferQueue<T> | |
| DataCollector | |
| RawBatchBuffer |
A batch buffer is responsible for queuing incoming batches until a consumer is ready to receive them.
|
| Class | Description |
|---|---|
| AbstractDataCollector | |
| BaseRawBatchBuffer<T> | |
| ControlMessageHandler | |
| FileTest | |
| IncomingBuffers |
Determines when a particular fragment has enough data for each of its receiving exchanges to commence execution.
|
| MergingCollector | |
| PartitionedCollector | |
| ResponseSenderQueue | |
| SpoolingRawBatchBuffer |
This implementation of RawBatchBuffer starts writing incoming batches to disk once the buffer size reaches a threshold.
|
| TestSpoolingBuffer | |
| UnlimitedRawBatchBuffer |
Copyright © 2021 The Apache Software Foundation. All rights reserved.