Uses of Interface
org.apache.storm.trident.operation.ReducerAggregator
Packages that use ReducerAggregator
Package
Description
- 
Uses of ReducerAggregator in org.apache.storm.tridentMethods in org.apache.storm.trident with parameters of type ReducerAggregatorModifier and TypeMethodDescriptionStream.aggregate(ReducerAggregator agg, Fields functionFields) Stream.aggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields) Stream.partitionAggregate(ReducerAggregator agg, Fields functionFields) Stream.partitionAggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields) Stream.persistentAggregate(StateFactory stateFactory, ReducerAggregator agg, Fields functionFields) Stream.persistentAggregate(StateFactory stateFactory, Fields inputFields, ReducerAggregator agg, Fields functionFields) Stream.persistentAggregate(StateSpec spec, ReducerAggregator agg, Fields functionFields) Stream.persistentAggregate(StateSpec spec, Fields inputFields, ReducerAggregator agg, Fields functionFields) 
- 
Uses of ReducerAggregator in org.apache.storm.trident.fluentMethods in org.apache.storm.trident.fluent with parameters of type ReducerAggregatorModifier and TypeMethodDescriptionChainedAggregatorDeclarer.aggregate(ReducerAggregator agg, Fields functionFields) ChainedAggregatorDeclarer.aggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields) ChainedFullAggregatorDeclarer.aggregate(ReducerAggregator agg, Fields functionFields) ChainedFullAggregatorDeclarer.aggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields) GroupedStream.aggregate(ReducerAggregator agg, Fields functionFields) GroupedStream.aggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields) ChainedAggregatorDeclarer.partitionAggregate(ReducerAggregator agg, Fields functionFields) ChainedAggregatorDeclarer.partitionAggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields) ChainedPartitionAggregatorDeclarer.partitionAggregate(ReducerAggregator agg, Fields functionFields) ChainedPartitionAggregatorDeclarer.partitionAggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields) GroupedStream.persistentAggregate(StateFactory stateFactory, ReducerAggregator agg, Fields functionFields) GroupedStream.persistentAggregate(StateFactory stateFactory, Fields inputFields, ReducerAggregator agg, Fields functionFields) GroupedStream.persistentAggregate(StateSpec spec, ReducerAggregator agg, Fields functionFields) GroupedStream.persistentAggregate(StateSpec spec, Fields inputFields, ReducerAggregator agg, Fields functionFields) 
- 
Uses of ReducerAggregator in org.apache.storm.trident.operation.implConstructors in org.apache.storm.trident.operation.impl with parameters of type ReducerAggregatorModifierConstructorDescription
- 
Uses of ReducerAggregator in org.apache.storm.trident.stateConstructors in org.apache.storm.trident.state with parameters of type ReducerAggregatorModifierConstructorDescriptionReducerValueUpdater(ReducerAggregator agg, List<TridentTuple> tuples) 
- 
Uses of ReducerAggregator in org.apache.storm.trident.state.mapConstructors in org.apache.storm.trident.state.map with parameters of type ReducerAggregatorModifierConstructorDescriptionMapReducerAggStateUpdater(ReducerAggregator agg, Fields groupFields, Fields inputFields)