| Package | Description | 
|---|---|
| org.apache.storm.hbase.trident.windowing | |
| org.apache.storm.trident.windowing | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | HBaseWindowsStoreThis class stores entries into hbase instance of the given configuration. | 
| Modifier and Type | Method and Description | 
|---|---|
| WindowsStore | HBaseWindowsStoreFactory. create(Map<String,Object> topoConf) | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | InMemoryWindowsStoreInmemory store implementation of  WindowsStorewhich can be backed by persistent store. | 
| Modifier and Type | Field and Description | 
|---|---|
| protected WindowsStore | AbstractTridentWindowManager. windowStore | 
| Modifier and Type | Method and Description | 
|---|---|
| WindowsStore | InMemoryWindowsStoreFactory. create(Map<String,Object> topoConf) | 
| WindowsStore | WindowsStoreFactory. create(Map<String,Object> topoConf)Creates a window store. | 
| 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) | 
| InMemoryWindowsStore(int maxSize,
                    WindowsStore backingStore)Creates a new in-memory window store. | 
| StoreBasedTridentWindowManager(WindowConfig windowConfig,
                              String windowTaskId,
                              WindowsStore windowStore,
                              Aggregator aggregator,
                              BatchOutputCollector delegateCollector,
                              Long maxTuplesCacheSize,
                              Fields inputFields) | 
Copyright © 2020 The Apache Software Foundation. All rights reserved.