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 | |
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.
|
UnlimitedRawBatchBuffer |
Copyright © 1970 The Apache Software Foundation. All rights reserved.