Package com.mulesoft.mule.runtime.module.batch.internal.engine.buffer

Interface Summary

Interface	Description
RecordBuffer	Buffer for holding records so that potentially slow operations can be performed in a bulk.

Class Summary

Class	Description
AbstractRecordBuffer	Base implementation of RecordBuffer which implements basic functionality such as the NamedObject interface, carrying the MuleContext and other functionality
AbstractStreamingAggregatorQueueBuffer	Base class for implementations of TransactionalQueueBuffer that rely on a BatchStep
AggregatorRecordBuffer	An implementation of RecordBuffer to be used by DefaultBatchStepAggregator instances.
BatchContextTransactionRecorder	Recorder for batch transaction contexts to prevent commit when an aggregator is flushed.
BufferUtils	Utilities for handling buffers
FixedAggregatorRecordBuffer	Implementation of AggregatorRecordBuffer for non streaming DefaultBatchStepAggregator.
FixedAggregatorTransactionRecordBuffer	Implementation of AggregatorRecordBuffer for non streaming DefaultBatchStepAggregator.
InMemoryRecordBuffer	Implementation of RecordBuffer which stores the records in memory until such time in which they're to be flushed.
LoadingQueueBuffer	Implementation of InMemoryRecordBuffer used to first load a stepping queue when a BatchJobInstanceAdapter is in BatchJobInstanceStatus.LOADING state
PartialErrorMatcher
SteppingQueueBuffer	Implementation of TransactionalQueueBuffer which flushes data using the BatchQueueDelegate returned by BatchQueueManager.steppingQueue(BatchJobInstanceAdapter)
StreamingAggregatorBuffer	An implementation of AggregatorRecordBuffer for streaming instances of DefaultBatchStepAggregator.
StreamingAggregatorInputQueueBuffer	Implementation of AbstractStreamingAggregatorQueueBuffer which flushes data using the BatchQueueDelegate returned by BatchQueueManager.streamingAggregatorInputQueue(com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceAdapter, com.mulesoft.mule.runtime.module.batch.engine.BatchStepAdapter)
StreamingAggregatorIteratorWrapper	Iterator to be used as the payload of an streaming aggregator.
StreamingAggregatorOutputQueueBuffer	Implementation of AbstractStreamingAggregatorQueueBuffer which flushes data using the BatchQueueDelegate returned by BatchQueueManager.streamingAggregatorOutputQueue(com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceAdapter, com.mulesoft.mule.runtime.module.batch.engine.BatchStepAdapter)
TransactionalQueueBuffer	Implementation of RecordBuffer that writes to a Queue when flushed.