| Package | Description |
|---|---|
| storm.trident.operation.impl | |
| storm.trident.state.map | |
| storm.trident.testing |
| Modifier and Type | Method and Description |
|---|---|
void |
ReducerAggStateUpdater.updateState(Snapshottable state,
List<TridentTuple> tuples,
TridentCollector collector) |
void |
CombinerAggStateUpdater.updateState(Snapshottable state,
List<TridentTuple> tuples,
TridentCollector collector) |
| Modifier and Type | Class and Description |
|---|---|
class |
SnapshottableMap<T> |
| Modifier and Type | Class and Description |
|---|---|
class |
LRUMemoryMapState<T> |
class |
MemoryMapState<T> |
Copyright © 2015. All rights reserved.