Package org.apache.storm.trident.windowing
package org.apache.storm.trident.windowing
-
ClassDescriptionBasic functionality to manage trident tuple events using
WindowManager
andWindowsStore
for storing tuples and triggers related information.ThisITridentWindowManager
instance stores all the tuples and trigger related information inmemory.Inmemory store implementation ofWindowsStore
which can be backed by persistent store.InMemoryWindowsStoreFactory contains a single instance ofInMemoryWindowsStore
which will be used for storing tuples and triggers of the window.Window manager to handle trident tuple events.This window manager usesWindowsStore
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 creatingWindowsState
instances.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 toputAll
method.Factory to create instances ofWindowsStore
.TridentProcessor
implementation for windowing operations on trident stream.