| Package | Description |
|---|---|
| org.gridgain.grid.kernal.processors.streamer |
TODO. |
| org.gridgain.grid.streamer |
Contains main Streaming APIs.
|
| org.gridgain.grid.streamer.window |
Contains streamer window implementations.
|
| Modifier and Type | Method and Description |
|---|---|
<E> GridStreamerWindow<E> |
GridStreamerContextDelegate.window()
Gets default event window, i.e.
|
<E> GridStreamerWindow<E> |
GridStreamerContextImpl.window()
Gets default event window, i.e.
|
<E> GridStreamerWindow<E> |
GridStreamerImpl.window()
Gets streamer default window (the first one in configuration list).
|
<E> GridStreamerWindow<E> |
GridStreamerEx.window()
Gets streamer default window (the first one in configuration list).
|
<E> GridStreamerWindow<E> |
GridStreamerContextDelegate.window(String winName)
Gets streamer event window by window name, if no window with such
name was configured
IllegalArgumentException will be thrown. |
<E> GridStreamerWindow<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> GridStreamerWindow<E> |
GridStreamerImpl.window(String windowName)
Gets streamer window by window name.
|
<E> GridStreamerWindow<E> |
GridStreamerEx.window(String windowName)
Gets streamer window by window name.
|
| Constructor and Description |
|---|
GridStreamerWindowMetricsHolder(GridStreamerWindow window) |
| Modifier and Type | Method and Description |
|---|---|
<E> GridStreamerWindow<E> |
GridStreamerContext.window()
Gets default event window, i.e.
|
<E> GridStreamerWindow<E> |
GridStreamerContext.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<GridStreamerWindow> |
GridStreamerConfiguration.getWindows()
Gets collection of streamer event windows.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridStreamerConfiguration.setWindows(Collection<GridStreamerWindow> win)
Sets collection of streamer windows.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridStreamerBoundedSizeBatchWindow<E>
Window that is bounded by size and accumulates events to batches.
|
class |
GridStreamerBoundedSizeSortedWindow<E>
Size-bounded sorted window.
|
class |
GridStreamerBoundedSizeWindow<E>
Queue window bounded by number of elements in queue.
|
class |
GridStreamerBoundedTimeBatchWindow<E>
Window that accumulates events in batches, and is bounded by time and maximum number of batches.
|
class |
GridStreamerBoundedTimeWindow<E>
Window which is bounded by size and time interval.
|
class |
GridStreamerUnboundedWindow<E>
Unbounded window which holds all events.
|
class |
GridStreamerWindowAdapter<E>
Streamer window adapter.
|
Copyright © 2014. All rights reserved.