Uses of Class
org.apache.storm.trident.state.StateSpec
Packages that use StateSpec
Package
Description
-
Uses of StateSpec in org.apache.storm.trident
Methods in org.apache.storm.trident with parameters of type StateSpecModifier and TypeMethodDescriptionTridentTopology.newStaticState
(StateSpec spec) Stream.partitionPersist
(StateSpec stateSpec, StateUpdater updater) Stream.partitionPersist
(StateSpec stateSpec, StateUpdater updater, Fields functionFields) Stream.partitionPersist
(StateSpec stateSpec, Fields inputFields, StateUpdater updater) Stream.partitionPersist
(StateSpec stateSpec, Fields inputFields, StateUpdater updater, Fields functionFields) Stream.persistentAggregate
(StateSpec spec, CombinerAggregator agg, Fields functionFields) Stream.persistentAggregate
(StateSpec spec, ReducerAggregator agg, Fields functionFields) Stream.persistentAggregate
(StateSpec spec, Fields inputFields, CombinerAggregator agg, Fields functionFields) Stream.persistentAggregate
(StateSpec spec, Fields inputFields, ReducerAggregator agg, Fields functionFields) -
Uses of StateSpec in org.apache.storm.trident.fluent
Methods in org.apache.storm.trident.fluent with parameters of type StateSpecModifier and TypeMethodDescriptionGroupedStream.persistentAggregate
(StateSpec spec, CombinerAggregator agg, Fields functionFields) GroupedStream.persistentAggregate
(StateSpec spec, ReducerAggregator agg, Fields functionFields) GroupedStream.persistentAggregate
(StateSpec spec, Fields inputFields, CombinerAggregator agg, Fields functionFields) GroupedStream.persistentAggregate
(StateSpec spec, Fields inputFields, ReducerAggregator agg, Fields functionFields) -
Uses of StateSpec in org.apache.storm.trident.planner
Fields in org.apache.storm.trident.planner declared as StateSpecConstructors in org.apache.storm.trident.planner with parameters of type StateSpec