Window manager to handle trident tuple events.
Store for storing window related entities like windowed tuples, triggers etc.
Factory to create instances of
Basic functionality to manage trident tuple events using
WindowsStore for storing tuples and triggers related information.
ITridentWindowManager instance stores all the tuples and trigger related information inmemory.
Inmemory store implementation of
WindowsStore which can be backed by persistent store.
InMemoryWindowsStoreFactory contains a single instance of
InMemoryWindowsStore which will be used for storing tuples and triggers of the window.
This window manager uses
WindowsStore for storing tuples and other trigger related information.
Kryo serializer/deserializer for values that are stored as part of windowing.
State implementation for windowing operation.
StateFactory instance for creating
StateUpdater<WindowState> instance which removes successfully emitted triggers from store.
This class wraps key and value objects which can be passed to
TridentProcessor implementation for windowing operations on trident stream.
Copyright © 2022 The Apache Software Foundation. All rights reserved.