| Interface | Description |
|---|---|
| ITridentWindowManager |
Window manager to handle trident tuple events.
|
| WindowsStore |
Store for storing window related entities like windowed tuples, triggers etc.
|
| WindowsStoreFactory |
Factory to create instances of
WindowsStore. |
| Class | Description |
|---|---|
| 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 |
Copyright © 2021 The Apache Software Foundation. All rights reserved.