public class StreamerBoundedTimeBatchWindow<E> extends StreamerWindowAdapter<E>
Constructor and Description |
---|
StreamerBoundedTimeBatchWindow() |
Modifier and Type | Method and Description |
---|---|
void |
checkConfiguration()
Check window configuration.
|
protected Collection<E> |
dequeue0(int cnt)
Dequeues up to cnt elements from window.
|
protected boolean |
enqueue0(E evt)
Adds event to window.
|
int |
evictionQueueSize()
Gets number of entries available for eviction.
|
int |
getBatchSize()
Gets batch size.
|
long |
getBatchTimeInterval()
Gets batch time interval.
|
int |
getMaximumBatches()
Gets maximum number of batches can be stored in window.
|
protected org.apache.ignite.internal.processors.streamer.GridStreamerWindowIterator<E> |
iterator0()
Returns an iterator over a set of elements of type T without check for iteration limit.
|
protected Collection<E> |
pollEvicted0(int cnt)
If window supports eviction, this method will return up to cnt evicted elements.
|
protected Collection<E> |
pollEvictedBatch0()
If window supports batch eviction, this method will poll next evicted batch from window.
|
protected void |
reset0()
Reset routine.
|
void |
setBatchSize(int batchSize)
Sets batch size.
|
void |
setBatchTimeInterval(long batchTimeInterval)
Sets batch time interval.
|
void |
setMaximumBatches(int maxBatches)
Sets maximum number of batches can be stored in window.
|
int |
size()
Gets number of events currently stored in window.
|
protected void |
stop0()
Dispose window.
|
clearEvicted, dequeue, dequeue, dequeueAll, enqueue, enqueue, enqueueAll, getClassName, getEvictionQueueSize, getFilter, getName, getSize, index, index, indexes, indexProviders, iterator, name, pollEvicted, pollEvicted, pollEvictedAll, pollEvictedBatch, reset, setFilter, setIndexes, setName, snapshot, start, stop, updateIndexes
public int getMaximumBatches()
public void setMaximumBatches(int maxBatches)
maxBatches
- Maximum number of batches for window.public int getBatchSize()
public void setBatchSize(int batchSize)
batchSize
- Batch size.public long getBatchTimeInterval()
public void setBatchTimeInterval(long batchTimeInterval)
batchTimeInterval
- Batch time interval.public void checkConfiguration()
checkConfiguration
in class StreamerWindowAdapter<E>
protected void stop0()
stop0
in class StreamerWindowAdapter<E>
protected void reset0()
reset0
in class StreamerWindowAdapter<E>
public int size()
protected org.apache.ignite.internal.processors.streamer.GridStreamerWindowIterator<E> iterator0()
iterator0
in class StreamerWindowAdapter<E>
public int evictionQueueSize()
protected boolean enqueue0(E evt)
enqueue0
in class StreamerWindowAdapter<E>
evt
- Event.True
if event added.protected Collection<E> pollEvicted0(int cnt)
pollEvicted0
in class StreamerWindowAdapter<E>
cnt
- Count.protected Collection<E> pollEvictedBatch0()
pollEvictedBatch0
in class StreamerWindowAdapter<E>
protected Collection<E> dequeue0(int cnt)
dequeue0
in class StreamerWindowAdapter<E>
cnt
- Count.
Follow @ApacheIgnite
Apache Ignite Fabric : ver. 1.0.0-RC3 Release Date : March 24 2015