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 © 2022 The Apache Software Foundation. All Rights Reserved.