Uses of Interface
org.apache.storm.trident.windowing.WindowsStoreFactory
Packages that use WindowsStoreFactory
Package
Description
-
Uses of WindowsStoreFactory in org.apache.storm.starter.trident
Methods in org.apache.storm.starter.trident with parameters of type WindowsStoreFactoryModifier and TypeMethodDescriptionstatic StormTopology
TridentWindowingInmemoryStoreTopology.buildTopology
(WindowsStoreFactory windowStore, WindowConfig windowConfig) -
Uses of WindowsStoreFactory in org.apache.storm.trident
Methods in org.apache.storm.trident with parameters of type WindowsStoreFactoryModifier and TypeMethodDescriptionStream.slidingWindow
(int windowCount, int slideCount, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, Fields functionFields) Returns a stream of tuples which are aggregated results of a sliding window with everywindowCount
of tuples and slides the window afterslideCount
.Stream.slidingWindow
(BaseWindowedBolt.Duration windowDuration, BaseWindowedBolt.Duration slidingInterval, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, Fields functionFields) Returns a stream of tuples which are aggregated results of a window which slides at duration ofslidingInterval
and completes a window atwindowDuration
.Stream.tumblingWindow
(int windowCount, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, Fields functionFields) Returns a stream of tuples which are aggregated results of a tumbling window with everywindowCount
of tuples.Stream.tumblingWindow
(BaseWindowedBolt.Duration windowDuration, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, Fields functionFields) Returns a stream of tuples which are aggregated results of a window that tumbles at duration ofwindowDuration
.Stream.window
(WindowConfig windowConfig, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, Fields functionFields) Returns stream of aggregated results based on the given window configuration. -
Uses of WindowsStoreFactory in org.apache.storm.trident.windowing
Classes in org.apache.storm.trident.windowing that implement WindowsStoreFactoryModifier and TypeClassDescriptionclass
InMemoryWindowsStoreFactory contains a single instance ofInMemoryWindowsStore
which will be used for storing tuples and triggers of the window.Constructors in org.apache.storm.trident.windowing with parameters of type WindowsStoreFactoryModifierConstructorDescriptionWindowsStateUpdater
(WindowsStoreFactory windowStoreFactory) WindowTridentProcessor
(WindowConfig windowConfig, String uniqueWindowId, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, boolean storeTuplesInStore)