Package | Description |
---|---|
org.apache.ignite.streamer |
Contains main Streaming APIs.
|
org.apache.ignite.streamer.window |
Contains streamer window implementations.
|
Modifier and Type | Method and Description |
---|---|
<E> StreamerWindow<E> |
StreamerContext.window()
Gets default event window, i.e. window that is on the first place in streamer configuration.
|
<E> StreamerWindow<E> |
StreamerContext.window(String winName)
Gets streamer event window by window name, if no window with such
name was configured
IllegalArgumentException will be thrown. |
Modifier and Type | Method and Description |
---|---|
Collection<StreamerWindow> |
StreamerConfiguration.getWindows()
Gets collection of streamer event windows.
|
Modifier and Type | Method and Description |
---|---|
void |
StreamerConfiguration.setWindows(Collection<StreamerWindow> win)
Sets collection of streamer windows.
|
Modifier and Type | Class and Description |
---|---|
class |
StreamerBoundedSizeBatchWindow<E>
Window that is bounded by size and accumulates events to batches.
|
class |
StreamerBoundedSizeSortedWindow<E>
Size-bounded sorted window.
|
class |
StreamerBoundedSizeWindow<E>
Queue window bounded by number of elements in queue.
|
class |
StreamerBoundedTimeBatchWindow<E>
Window that accumulates events in batches, and is bounded by time and maximum number of batches.
|
class |
StreamerBoundedTimeWindow<E>
Window which is bounded by size and time interval.
|
class |
StreamerUnboundedWindow<E>
Unbounded window which holds all events.
|
class |
StreamerWindowAdapter<E>
Streamer window adapter.
|
Follow @ApacheIgnite
Apache Ignite Fabric : ver. 1.0.0-RC3 Release Date : March 24 2015