Package org.apache.storm.trident.windowing
package org.apache.storm.trident.windowing
-
ClassDescriptionBasic functionality to manage trident tuple events using
WindowManagerandWindowsStorefor storing tuples and triggers related information.ThisITridentWindowManagerinstance stores all the tuples and trigger related information inmemory.Inmemory store implementation ofWindowsStorewhich can be backed by persistent store.InMemoryWindowsStoreFactory contains a single instance ofInMemoryWindowsStorewhich will be used for storing tuples and triggers of the window.Window manager to handle trident tuple events.This window manager usesWindowsStorefor 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 creatingWindowsStateinstances.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 toputAllmethod.Factory to create instances ofWindowsStore.TridentProcessorimplementation for windowing operations on trident stream.