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

Packages that use WindowsStoreFactory

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

Uses of WindowsStoreFactory in org.apache.storm.hbase.trident.windowing

Classes in org.apache.storm.hbase.trident.windowing that implement WindowsStoreFactory

Modifier and Type	Class and Description
class	HBaseWindowsStoreFactory Factory to create HBaseWindowsStore instances.

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 and Description
static StormTopology	TridentHBaseWindowingStoreTopology.buildTopology(WindowsStoreFactory windowsStore)
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 and Description
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.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.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.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.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 and 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 and Description
WindowsStateUpdater(WindowsStoreFactory windowStoreFactory)
WindowTridentProcessor(WindowConfig windowConfig, String uniqueWindowId, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, boolean storeTuplesInStore)