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

Packages that use CombinerAggregator

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

Uses of CombinerAggregator in org.apache.storm.starter.trident

Classes in org.apache.storm.starter.trident that implement CombinerAggregator

Modifier and Type	Class	Description
static class	TridentReach.One

Uses of CombinerAggregator in org.apache.storm.trident

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

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

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

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

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

Uses of CombinerAggregator in org.apache.storm.trident.operation.builtin

Classes in org.apache.storm.trident.operation.builtin that implement CombinerAggregator

Modifier and Type	Class	Description
class	Count
class	Sum

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

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

Modifier	Constructor	Description
	CombinerAggregatorCombineImpl(CombinerAggregator agg)
	CombinerAggregatorInitImpl(CombinerAggregator agg)
	CombinerAggStateUpdater(CombinerAggregator agg)

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

Methods in org.apache.storm.trident.state that return CombinerAggregator

Modifier and Type	Method	Description
CombinerAggregator	CombinerValueUpdater.getAgg()

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

Modifier	Constructor	Description
	CombinerValueUpdater(CombinerAggregator agg, Object arg)

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

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

Modifier	Constructor	Description
	MapCombinerAggStateUpdater(CombinerAggregator agg, Fields groupFields, Fields inputFields)