Package | Description |
---|---|
org.apache.storm.hbase.trident.windowing | |
org.apache.storm.trident.windowing |
Modifier and Type | Class and Description |
---|---|
class |
HBaseWindowsStore
This 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 |
InMemoryWindowsStore
Inmemory store implementation of
WindowsStore which can be backed by persistent store. |
Modifier and Type | Field and Description |
---|---|
protected WindowsStore |
AbstractTridentWindowManager.windowStore |
Modifier and Type | Method and Description |
---|---|
WindowsStore |
WindowsStoreFactory.create(Map<String,Object> topoConf)
Creates a window store.
|
WindowsStore |
InMemoryWindowsStoreFactory.create(Map<String,Object> topoConf) |
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 © 2022 The Apache Software Foundation. All rights reserved.