Package | Description |
---|---|
org.apache.storm.hbase.trident.state | |
org.apache.storm.redis.trident.state | |
org.apache.storm.trident.state.map | |
org.apache.storm.trident.testing |
Modifier and Type | Class and Description |
---|---|
class |
HBaseMapState<T> |
Modifier and Type | Class and Description |
---|---|
class |
AbstractRedisMapState<T>
AbstractRedisMapState is base class of any RedisMapState, which implements IBackingMap.
|
class |
RedisClusterMapState<T>
IBackingMap implementation for Redis Cluster environment.
|
class |
RedisMapState<T>
IBackingMap implementation for single Redis environment.
|
Modifier and Type | Class and Description |
---|---|
class |
CachedMap<T>
Useful to layer over a map that communicates with a database.
|
class |
MicroBatchIBackingMap<T> |
Modifier and Type | Field and Description |
---|---|
IBackingMap<T> |
CachedBatchReadsMap._delegate |
Modifier and Type | Method and Description |
---|---|
static <T> MapState<T> |
OpaqueMap.build(IBackingMap<OpaqueValue> backing) |
static <T> MapState<T> |
NonTransactionalMap.build(IBackingMap<T> backing) |
static <T> MapState<T> |
TransactionalMap.build(IBackingMap<TransactionalValue> backing) |
Constructor and Description |
---|
CachedBatchReadsMap(IBackingMap<T> delegate) |
CachedMap(IBackingMap<T> delegate,
int cacheSize) |
MicroBatchIBackingMap(MicroBatchIBackingMap.Options options,
IBackingMap<T> delegate) |
NonTransactionalMap(IBackingMap<T> backing) |
OpaqueMap(IBackingMap<OpaqueValue> backing) |
TransactionalMap(IBackingMap<TransactionalValue> backing) |
Modifier and Type | Class and Description |
---|---|
class |
MemoryBackingMap |
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.