| AbstractTridentWindowManager<T> |
Basic functionality to manage trident tuple events using WindowManager and WindowsStore for storing tuples and triggers
related information.
|
| InMemoryTridentWindowManager |
This ITridentWindowManager instance stores all the tuples and trigger related information inmemory.
|
| InMemoryWindowsStore |
Inmemory store implementation of WindowsStore which can be backed by persistent store.
|
| InMemoryWindowsStoreFactory |
InMemoryWindowsStoreFactory contains a single instance of InMemoryWindowsStore which will be used for storing tuples and triggers
of the window. |
| StoreBasedTridentWindowManager |
This window manager uses WindowsStore for storing tuples and other trigger related information.
|
| TridentBatchTuple |
|
| WindowKryoSerializer |
Kryo serializer/deserializer for values that are stored as part of windowing.
|
| WindowsState |
State implementation for windowing operation.
|
| WindowsStateFactory |
StateFactory instance for creating WindowsState instances.
|
| WindowsStateUpdater |
StateUpdater<WindowState> instance which removes successfully emitted triggers from store.
|
| WindowsStore.Entry |
This class wraps key and value objects which can be passed to putAll method.
|
| WindowTridentProcessor |
TridentProcessor implementation for windowing operations on trident stream.
|
| WindowTridentProcessor.TriggerInfo |
|