org.apache.ignite.internal.processors.continuous

Class GridContinuousBatchAdapter

java.lang.Object

org.apache.ignite.internal.processors.continuous.GridContinuousBatchAdapter

All Implemented Interfaces:

GridContinuousBatch

Direct Known Subclasses:

GridContinuousQueryBatch

public class GridContinuousBatchAdapter
extends Object
implements GridContinuousBatch

Continuous routine batch adapter.

Field Summary

Fields

Modifier and Type	Field and Description
protected ConcurrentLinkedDeque8<Object>	buf Buffer.

Constructor Summary

Constructors

Constructor and Description
GridContinuousBatchAdapter()

Method Summary

Methods

Modifier and Type	Method and Description
void	add(Object obj) Adds element to this batch.
Collection<Object>	collect() Collects elements that are currently in this batch.
int	size()

Methods inherited from class java.lang.Object

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

Field Detail

buf

protected final ConcurrentLinkedDeque8<Object> buf

Buffer.

Constructor Detail

GridContinuousBatchAdapter

public GridContinuousBatchAdapter()

Method Detail

add

public void add(Object obj)

Adds element to this batch.

Specified by:

add in interface GridContinuousBatch

Parameters:

obj - Element to add.

collect

public Collection<Object> collect()

Collects elements that are currently in this batch.

Specified by:

collect in interface GridContinuousBatch

Returns:

Elements in this batch.

size

public int size()

Specified by:

size in interface GridContinuousBatch

Returns:

Current batch size.