ClassDescriptionBasic functionality to manage trident tuple events using
WindowsStorefor storing tuples and triggers related information.This
ITridentWindowManagerinstance stores all the tuples and trigger related information inmemory.Inmemory store implementation of
WindowsStorewhich can be backed by persistent store.InMemoryWindowsStoreFactory contains a single instance of
InMemoryWindowsStorewhich will be used for storing tuples and triggers of the window.Window manager to handle trident tuple events.This window manager uses
WindowsStorefor storing tuples and other trigger related information.Kryo serializer/deserializer for values that are stored as part of windowing.
Stateimplementation for windowing operation.
StateFactoryinstance for creating
StateUpdater<WindowState>instance which removes successfully emitted triggers from store.Store for storing window related entities like windowed tuples, triggers etc.This class wraps key and value objects which can be passed to
putAllmethod.Factory to create instances of
TridentProcessorimplementation for windowing operations on trident stream.