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 Description protected FastSizeDeque<Object>bufBuffer.
-
Constructor Summary
Constructors Constructor Description GridContinuousBatchAdapter()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidadd(Object obj)Adds element to this batch.Collection<Object>collect()Collects elements that are currently in this batch.intsize()
-
-
-
Field Detail
-
buf
protected final FastSizeDeque<Object> buf
Buffer.
-
-
Method Detail
-
add
public void add(Object obj)
Adds element to this batch.- Specified by:
addin interfaceGridContinuousBatch- Parameters:
obj- Element to add.
-
collect
public Collection<Object> collect()
Collects elements that are currently in this batch.- Specified by:
collectin interfaceGridContinuousBatch- Returns:
- Elements in this batch.
-
size
public int size()
- Specified by:
sizein interfaceGridContinuousBatch- Returns:
- Current batch size.
-
-