Package | Description |
---|---|
org.apache.storm.starter.trident | |
org.apache.storm.trident.state.map | |
org.apache.storm.trident.testing |
Modifier and Type | Class and Description |
---|---|
class |
DebugMemoryMapState<T> |
Modifier and Type | Class and Description |
---|---|
class |
NonTransactionalMap<T> |
class |
OpaqueMap<T> |
class |
SnapshottableMap<T> |
class |
TransactionalMap<T> |
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) |
Modifier and Type | Method and Description |
---|---|
void |
MapReducerAggStateUpdater.updateState(MapState map,
List<TridentTuple> tuples,
TridentCollector collector) |
void |
MapCombinerAggStateUpdater.updateState(MapState map,
List<TridentTuple> tuples,
TridentCollector collector) |
Constructor and Description |
---|
SnapshottableMap(MapState<T> delegate,
List<Object> snapshotKey) |
Modifier and Type | Class and Description |
---|---|
class |
LRUMemoryMapState<T> |
class |
MemoryMapState<T> |
Copyright © 2022 The Apache Software Foundation. All rights reserved.