Uses of Interface
org.apache.storm.trident.operation.ReducerAggregator

Packages that use ReducerAggregator

Package	Description
org.apache.storm.trident
org.apache.storm.trident.fluent
org.apache.storm.trident.operation.impl
org.apache.storm.trident.state
org.apache.storm.trident.state.map

Uses of ReducerAggregator in org.apache.storm.trident

Methods in org.apache.storm.trident with parameters of type ReducerAggregator

Modifier and Type	Method	Description
Stream	Stream.aggregate(ReducerAggregator agg, Fields functionFields)
Stream	Stream.aggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields)
Stream	Stream.partitionAggregate(ReducerAggregator agg, Fields functionFields)
Stream	Stream.partitionAggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields)
TridentState	Stream.persistentAggregate(StateFactory stateFactory, ReducerAggregator agg, Fields functionFields)
TridentState	Stream.persistentAggregate(StateFactory stateFactory, Fields inputFields, ReducerAggregator agg, Fields functionFields)
TridentState	Stream.persistentAggregate(StateSpec spec, ReducerAggregator agg, Fields functionFields)
TridentState	Stream.persistentAggregate(StateSpec spec, Fields inputFields, ReducerAggregator agg, Fields functionFields)

Uses of ReducerAggregator in org.apache.storm.trident.fluent

Methods in org.apache.storm.trident.fluent with parameters of type ReducerAggregator

Modifier and Type	Method	Description
ChainedFullAggregatorDeclarer	ChainedAggregatorDeclarer.aggregate(ReducerAggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	ChainedAggregatorDeclarer.aggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	ChainedFullAggregatorDeclarer.aggregate(ReducerAggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	ChainedFullAggregatorDeclarer.aggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields)
Stream	GroupedStream.aggregate(ReducerAggregator agg, Fields functionFields)
Stream	GroupedStream.aggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedAggregatorDeclarer.partitionAggregate(ReducerAggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedAggregatorDeclarer.partitionAggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedPartitionAggregatorDeclarer.partitionAggregate(ReducerAggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedPartitionAggregatorDeclarer.partitionAggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields)
TridentState	GroupedStream.persistentAggregate(StateFactory stateFactory, ReducerAggregator agg, Fields functionFields)
TridentState	GroupedStream.persistentAggregate(StateFactory stateFactory, Fields inputFields, ReducerAggregator agg, Fields functionFields)
TridentState	GroupedStream.persistentAggregate(StateSpec spec, ReducerAggregator agg, Fields functionFields)
TridentState	GroupedStream.persistentAggregate(StateSpec spec, Fields inputFields, ReducerAggregator agg, Fields functionFields)

Uses of ReducerAggregator in org.apache.storm.trident.operation.impl

Constructors in org.apache.storm.trident.operation.impl with parameters of type ReducerAggregator

Modifier	Constructor	Description
	ReducerAggregatorImpl(ReducerAggregator agg)
	ReducerAggStateUpdater(ReducerAggregator agg)

Uses of ReducerAggregator in org.apache.storm.trident.state

Constructors in org.apache.storm.trident.state with parameters of type ReducerAggregator

Modifier	Constructor	Description
	ReducerValueUpdater(ReducerAggregator agg, List<TridentTuple> tuples)

Uses of ReducerAggregator in org.apache.storm.trident.state.map

Constructors in org.apache.storm.trident.state.map with parameters of type ReducerAggregator

Modifier	Constructor	Description
	MapReducerAggStateUpdater(ReducerAggregator agg, Fields groupFields, Fields inputFields)