| Package | Description |
|---|---|
| org.apache.ignite.internal.processors.streamer |
TODO. |
| 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> |
IgniteStreamerImpl.window()
Gets streamer default window (the first one in configuration list).
|
<E> StreamerWindow<E> |
IgniteStreamerEx.window()
Gets streamer default window (the first one in configuration list).
|
<E> StreamerWindow<E> |
GridStreamerContextImpl.window()
Gets default event window, i.e. window that is on the first place in streamer configuration.
|
<E> StreamerWindow<E> |
GridStreamerContextDelegate.window()
Gets default event window, i.e. window that is on the first place in streamer configuration.
|
<E> StreamerWindow<E> |
IgniteStreamerImpl.window(String windowName)
Gets streamer window by window name.
|
<E> StreamerWindow<E> |
IgniteStreamerEx.window(String windowName)
Gets streamer window by window name.
|
<E> StreamerWindow<E> |
GridStreamerContextImpl.window(String winName)
Gets streamer event window by window name, if no window with such
name was configured
IllegalArgumentException will be thrown. |
<E> StreamerWindow<E> |
GridStreamerContextDelegate.window(String winName)
Gets streamer event window by window name, if no window with such
name was configured
IllegalArgumentException will be thrown. |
| Constructor and Description |
|---|
StreamerWindowMetricsHolder(StreamerWindow window) |
| 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
Ignite Fabric : ver. 1.0.0-RC3 Release Date : March 24 2015