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

Class StreamingAggregatorIteratorWrapper

java.lang.Object

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

All Implemented Interfaces:

Iterator<Object>, org.mule.runtime.api.streaming.HasSize, org.mule.runtime.core.api.Closeable, org.mule.runtime.core.internal.routing.outbound.EventBuilderConfigurerIterator<Object>

public class StreamingAggregatorIteratorWrapper
extends Object
implements org.mule.runtime.core.internal.routing.outbound.EventBuilderConfigurerIterator<Object>, org.mule.runtime.api.streaming.HasSize, org.mule.runtime.core.api.Closeable

Iterator to be used as the payload of an streaming aggregator. As the delegate iterator is consumed, the elements obtained from it are accumulated into an output RecordBuffer

Since:

4.3.0

Constructor Summary

Constructors

Constructor and Description
StreamingAggregatorIteratorWrapper(Iterator<List<Record>> delegate, BatchTransactionContextProvider outputContextProvider, BatchTransactionContext ctx, BatchJobInstanceAdapter jobInstance, RecordBuffer outputQueueBuffer, int blockSize)

Method Summary

Modifier and Type	Method and Description
void	close()
void	commit()
Record	getPrevious()
int	getSize()
boolean	hasNext()
Object	next()
org.mule.runtime.core.internal.routing.outbound.EventBuilderConfigurer	nextEventBuilderConfigurer()
protected org.mule.runtime.api.util.Pair<Record,RecordELAdapter>	nextRecord()
void	remove()
void	rollback()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining

Constructor Detail

StreamingAggregatorIteratorWrapper

public StreamingAggregatorIteratorWrapper(Iterator<List<Record>> delegate,
                                          BatchTransactionContextProvider outputContextProvider,
                                          BatchTransactionContext ctx,
                                          BatchJobInstanceAdapter jobInstance,
                                          RecordBuffer outputQueueBuffer,
                                          int blockSize)

Method Detail

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<Object>

nextRecord

protected org.mule.runtime.api.util.Pair<Record,RecordELAdapter> nextRecord()

next

public Object next()

Specified by:

next in interface Iterator<Object>

nextEventBuilderConfigurer

public org.mule.runtime.core.internal.routing.outbound.EventBuilderConfigurer nextEventBuilderConfigurer()

Specified by:

nextEventBuilderConfigurer in interface org.mule.runtime.core.internal.routing.outbound.EventBuilderConfigurerIterator<Object>

close

public void close()
           throws org.mule.runtime.api.exception.MuleException

Specified by:

close in interface org.mule.runtime.core.api.Closeable

Throws:

org.mule.runtime.api.exception.MuleException

commit

public void commit()

rollback

public void rollback()

remove

public void remove()

Specified by:

remove in interface Iterator<Object>

getSize

public int getSize()

Specified by:

getSize in interface org.mule.runtime.api.streaming.HasSize

getPrevious

public Record getPrevious()