| 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 © 2019 The Apache Software Foundation. All Rights Reserved.