Modifier and Type | Method and Description |
---|---|
static StormTopology |
TridentWindowingInmemoryStoreTopology.buildTopology(WindowsStoreFactory windowStore,
WindowConfig windowConfig) |
Modifier and Type | Method and Description |
---|---|
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.
|
Stream |
Stream.window(WindowConfig windowConfig,
WindowsStoreFactory windowStoreFactory,
Fields inputFields,
Aggregator aggregator,
Fields functionFields)
Returns stream of aggregated results based on the given window configuration.
|
Constructor and 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) |
Modifier and Type | Class and 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.
|
Modifier and Type | Field and Description |
---|---|
protected WindowConfig |
BaseWindowStrategy.windowConfig |
Constructor and Description |
---|
BaseWindowStrategy(WindowConfig windowConfig) |
SlidingCountWindowStrategy(WindowConfig slidingCountWindow) |
SlidingDurationWindowStrategy(WindowConfig slidingDurationWindow) |
TumblingCountWindowStrategy(WindowConfig tumblingCountWindow) |
TumblingDurationWindowStrategy(WindowConfig tumblingDurationWindow) |
Copyright © 2023 The Apache Software Foundation. All rights reserved.