TridentState |
TridentTopology.newStaticState(StateSpec spec) |
TridentState |
Stream.partitionPersist(StateSpec stateSpec,
Fields inputFields,
StateUpdater updater) |
TridentState |
Stream.partitionPersist(StateSpec stateSpec,
Fields inputFields,
StateUpdater updater,
Fields functionFields) |
TridentState |
Stream.partitionPersist(StateSpec stateSpec,
StateUpdater updater) |
TridentState |
Stream.partitionPersist(StateSpec stateSpec,
StateUpdater updater,
Fields functionFields) |
TridentState |
Stream.persistentAggregate(StateSpec spec,
CombinerAggregator agg,
Fields functionFields) |
TridentState |
Stream.persistentAggregate(StateSpec spec,
Fields inputFields,
CombinerAggregator agg,
Fields functionFields) |
TridentState |
Stream.persistentAggregate(StateSpec spec,
Fields inputFields,
ReducerAggregator agg,
Fields functionFields) |
TridentState |
Stream.persistentAggregate(StateSpec spec,
ReducerAggregator agg,
Fields functionFields) |