Uses of Interface
org.apache.storm.trident.windowing.WindowsStoreFactory

Packages that use WindowsStoreFactory

Package	Description
org.apache.storm.starter.trident
org.apache.storm.trident
org.apache.storm.trident.windowing

Uses of WindowsStoreFactory in org.apache.storm.starter.trident

Methods in org.apache.storm.starter.trident with parameters of type WindowsStoreFactory

Modifier and Type	Method	Description
static 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 WindowsStoreFactory

Modifier and Type	Method	Description
Stream	Stream.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 every windowCount of tuples and slides the window after slideCount.
Stream	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 of slidingInterval and completes a window at windowDuration.
Stream	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 every windowCount of tuples.
Stream	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 of windowDuration.
Stream	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 WindowsStoreFactory

Modifier and Type	Class	Description
class	InMemoryWindowsStoreFactory	InMemoryWindowsStoreFactory contains a single instance of InMemoryWindowsStore which will be used for storing tuples and triggers of the window.

Constructors in org.apache.storm.trident.windowing with parameters of type WindowsStoreFactory

Constructor	Description
WindowsStateUpdater(WindowsStoreFactory windowStoreFactory)
WindowTridentProcessor(WindowConfig windowConfig, String uniqueWindowId, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, boolean storeTuplesInStore)