class |
AbstractStreamingAggregatorQueueBuffer
|
class |
AggregatorRecordBuffer
|
class |
FixedAggregatorRecordBuffer
|
class |
FixedAggregatorTransactionRecordBuffer
|
class |
InMemoryRecordBuffer
Implementation of RecordBuffer which stores the records in memory until such time in which they're to be flushed.
|
class |
LoadingQueueBuffer
|
class |
SteppingQueueBuffer
|
class |
StreamingAggregatorBuffer
|
class |
StreamingAggregatorInputQueueBuffer
|
class |
StreamingAggregatorOutputQueueBuffer
|
class |
TransactionalQueueBuffer
Implementation of RecordBuffer that writes to a Queue when flushed.
|