Uses of Interface
org.apache.storm.trident.windowing.config.WindowConfig
-
-
Uses of WindowConfig in org.apache.storm.starter.trident
Methods in org.apache.storm.starter.trident with parameters of type WindowConfig Modifier and Type Method Description static StormTopology
TridentWindowingInmemoryStoreTopology. buildTopology(WindowsStoreFactory windowStore, WindowConfig windowConfig)
-
Uses of WindowConfig in org.apache.storm.trident
Methods in org.apache.storm.trident with parameters of type WindowConfig Modifier and Type Method Description Stream
Stream. window(WindowConfig windowConfig, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, Fields functionFields)
Returns stream of aggregated results based on the given window configuration.Stream
Stream. window(WindowConfig windowConfig, Fields inputFields, Aggregator aggregator, Fields functionFields)
Returns a stream of aggregated results based on the given window configuration which uses inmemory windowing tuple store. -
Uses of WindowConfig in org.apache.storm.trident.windowing
Constructors in org.apache.storm.trident.windowing with parameters of type WindowConfig Constructor Description AbstractTridentWindowManager(WindowConfig windowConfig, String windowTaskId, WindowsStore windowStore, Aggregator aggregator, BatchOutputCollector delegateCollector)
InMemoryTridentWindowManager(WindowConfig windowConfig, String windowTaskId, WindowsStore windowStore, Aggregator aggregator, BatchOutputCollector delegateCollector)
StoreBasedTridentWindowManager(WindowConfig windowConfig, String windowTaskId, WindowsStore windowStore, Aggregator aggregator, BatchOutputCollector delegateCollector, Long maxTuplesCacheSize, Fields inputFields)
WindowTridentProcessor(WindowConfig windowConfig, String uniqueWindowId, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, boolean storeTuplesInStore)
-
Uses of WindowConfig in org.apache.storm.trident.windowing.config
Classes in org.apache.storm.trident.windowing.config that implement WindowConfig Modifier and Type Class Description class
BaseWindowConfig
class
SlidingCountWindow
Represents configuration of sliding window based on count of events.class
SlidingDurationWindow
Represents configuration of sliding window based on duration.class
TumblingCountWindow
Represents tumbling count window configuration.class
TumblingDurationWindow
Represents tumbling duration window configuration. -
Uses of WindowConfig in org.apache.storm.trident.windowing.strategy
Fields in org.apache.storm.trident.windowing.strategy declared as WindowConfig Modifier and Type Field Description protected WindowConfig
BaseWindowStrategy. windowConfig
Constructors in org.apache.storm.trident.windowing.strategy with parameters of type WindowConfig Constructor Description BaseWindowStrategy(WindowConfig windowConfig)
SlidingCountWindowStrategy(WindowConfig slidingCountWindow)
SlidingDurationWindowStrategy(WindowConfig slidingDurationWindow)
TumblingCountWindowStrategy(WindowConfig tumblingCountWindow)
TumblingDurationWindowStrategy(WindowConfig tumblingDurationWindow)
-