public class StreamerUnboundedWindow<E> extends StreamerWindowAdapter<E>
dequeue(...)
methods.Constructor and Description |
---|
StreamerUnboundedWindow() |
Modifier and Type | Method and Description |
---|---|
void |
checkConfiguration()
Check window configuration.
|
protected Collection<E> |
dequeue0(int cnt)
Dequeues up to cnt elements from window.
|
boolean |
enqueue0(E evt)
Adds event to window.
|
int |
evictionQueueSize()
Gets number of entries available for eviction.
|
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.
|
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
protected void stop0()
stop0
in class StreamerWindowAdapter<E>
public void checkConfiguration()
checkConfiguration
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()
public boolean enqueue0(E evt)
enqueue0
in class StreamerWindowAdapter<E>
evt
- Event.True
if event added.protected Collection<E> dequeue0(int cnt)
dequeue0
in class StreamerWindowAdapter<E>
cnt
- Count.protected Collection<E> pollEvicted0(int cnt)
pollEvicted0
in class StreamerWindowAdapter<E>
cnt
- Count.protected Collection<E> pollEvictedBatch0()
pollEvictedBatch0
in class StreamerWindowAdapter<E>
Follow @ApacheIgnite
Apache Ignite Fabric : ver. 1.0.0-RC1 Release Date : February 16 2015