Uses of Interface
org.apache.storm.trident.windowing.config.WindowConfig
Package
Description
-
Uses of WindowConfig in org.apache.storm.starter.trident
Modifier and TypeMethodDescriptionstatic StormTopology
TridentWindowingInmemoryStoreTopology.buildTopology
(WindowsStoreFactory windowStore, WindowConfig windowConfig) -
Uses of WindowConfig in org.apache.storm.trident
Modifier and TypeMethodDescriptionStream.window
(WindowConfig windowConfig, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, Fields functionFields) Returns stream of aggregated results based on the given window configuration.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
ModifierConstructorDescriptionAbstractTridentWindowManager
(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
Modifier and TypeClassDescriptionclass
final class
Represents configuration of sliding window based on count of events.final class
Represents configuration of sliding window based on duration.final class
Represents tumbling count window configuration.final class
Represents tumbling duration window configuration. -
Uses of WindowConfig in org.apache.storm.trident.windowing.strategy
ModifierConstructorDescriptionBaseWindowStrategy
(WindowConfig windowConfig) SlidingCountWindowStrategy
(WindowConfig slidingCountWindow) SlidingDurationWindowStrategy
(WindowConfig slidingDurationWindow) TumblingCountWindowStrategy
(WindowConfig tumblingCountWindow) TumblingDurationWindowStrategy
(WindowConfig tumblingDurationWindow)