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

Class StreamingAggregatorInputQueueBuffer

java.lang.Object

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

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

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

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

All Implemented Interfaces:

BatchContextTransactionManager, RecordBuffer, org.mule.runtime.api.meta.NamedObject

public class StreamingAggregatorInputQueueBuffer
extends AbstractStreamingAggregatorQueueBuffer

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)

Since:

3.5.0

Field Summary

Fields inherited from class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.AbstractStreamingAggregatorQueueBuffer

step

Fields inherited from class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.TransactionalQueueBuffer

batchQueueManager

Constructor Summary

Constructors

Constructor and Description
StreamingAggregatorInputQueueBuffer(BatchEngine batchEngine, BatchStepAdapter step)

Method Summary

Modifier and Type	Method and Description
protected void	doFlush(BatchJobInstanceAdapter jobInstance, BatchTransactionContext ctx, List<Record> records)
protected void	doForget(BatchJobInstanceAdapter jobInstance)
protected BatchQueueDelegate	getDelegate(BatchJobInstanceAdapter jobInstance) Returns a BatchQueueDelegate for streaming aggregator queues
long	getFlushedRecordCount(com.mulesoft.mule.runtime.module.batch.api.BatchJobInstance jobInstance)

Methods inherited from class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.TransactionalQueueBuffer

add, commit, flush, flushAndForget, forget, rollback, size

Methods inherited from class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.AbstractRecordBuffer

add, getName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StreamingAggregatorInputQueueBuffer

public StreamingAggregatorInputQueueBuffer(BatchEngine batchEngine,
                                           BatchStepAdapter step)

Method Detail

getDelegate

protected BatchQueueDelegate getDelegate(BatchJobInstanceAdapter jobInstance)

Returns a BatchQueueDelegate for streaming aggregator queues

Specified by:

getDelegate in class TransactionalQueueBuffer

Returns:

a BatchQueueDelegate

getFlushedRecordCount

public long getFlushedRecordCount(com.mulesoft.mule.runtime.module.batch.api.BatchJobInstance jobInstance)

doFlush

protected void doFlush(BatchJobInstanceAdapter jobInstance,
                       BatchTransactionContext ctx,
                       List<Record> records)

Overrides:

doFlush in class TransactionalQueueBuffer

doForget

protected void doForget(BatchJobInstanceAdapter jobInstance)

Overrides:

doForget in class TransactionalQueueBuffer