| Package | Description |
|---|---|
| org.apache.ignite.streamer.window |
Contains streamer window implementations.
|
| Modifier and Type | Method and Description |
|---|---|
protected GridStreamerWindowIterator<E> |
StreamerUnboundedWindow.iterator0()
Returns an iterator over a set of elements of type T without check for iteration limit.
|
protected GridStreamerWindowIterator<E> |
StreamerBoundedTimeBatchWindow.iterator0()
Returns an iterator over a set of elements of type T without check for iteration limit.
|
protected GridStreamerWindowIterator<E> |
StreamerBoundedTimeWindow.iterator0()
Returns an iterator over a set of elements of type T without check for iteration limit.
|
protected GridStreamerWindowIterator<E> |
StreamerBoundedSizeBatchWindow.iterator0()
Returns an iterator over a set of elements of type T without check for iteration limit.
|
protected abstract GridStreamerWindowIterator<E> |
StreamerWindowAdapter.iterator0()
Returns an iterator over a set of elements of type T without check for iteration limit.
|
GridStreamerWindowIterator<E> |
StreamerBoundedSizeWindow.iteratorInternal(Collection<E> col,
Set<E> set,
AtomicInteger size)
Creates iterator based on implementation collection type.
|
protected GridStreamerWindowIterator<E> |
StreamerBoundedSizeSortedWindow.iteratorInternal(Collection<org.apache.ignite.streamer.window.StreamerBoundedSizeSortedWindow.Holder<E>> col,
Set<E> set,
AtomicInteger size)
Creates iterator based on implementation collection type.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 1.0.0-RC3 Release Date : March 24 2015