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 stormConf) |
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 stormConf)
Creates a window store
|
WindowsStore |
InMemoryWindowsStoreFactory.create(Map stormConf) |
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) |
StoreBasedTridentWindowManager(WindowConfig windowConfig,
String windowTaskId,
WindowsStore windowStore,
Aggregator aggregator,
BatchOutputCollector delegateCollector,
Long maxTuplesCacheSize,
Fields inputFields) |
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.