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.
FixedAggregatorRecordBuffer	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)
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.