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 StormTopologyTridentWindowingInmemoryStoreTopology.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 everywindowCountof 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 ofslidingIntervaland 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 everywindowCountof 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 TypeClassDescriptionclassInMemoryWindowsStoreFactory contains a single instance ofInMemoryWindowsStorewhich 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)