Uses of Interface
storm.trident.operation.CombinerAggregator

Packages that use CombinerAggregator

Package	Description
storm.trident
storm.trident.fluent
storm.trident.operation.builtin
storm.trident.operation.impl
storm.trident.state
storm.trident.state.map

Uses of CombinerAggregator in storm.trident

Methods in storm.trident with parameters of type CombinerAggregator

Modifier and Type	Method and 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 storm.trident.fluent

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

Modifier and Type	Method and Description
Stream	GroupedStream.aggregate(CombinerAggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	ChainedAggregatorDeclarer.aggregate(CombinerAggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	ChainedFullAggregatorDeclarer.aggregate(CombinerAggregator agg, Fields functionFields)
Stream	GroupedStream.aggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	ChainedAggregatorDeclarer.aggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	ChainedFullAggregatorDeclarer.aggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedPartitionAggregatorDeclarer.partitionAggregate(CombinerAggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedAggregatorDeclarer.partitionAggregate(CombinerAggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedPartitionAggregatorDeclarer.partitionAggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedAggregatorDeclarer.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 storm.trident.operation.builtin

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

Modifier and Type	Class and Description
class	Count
class	Sum

Uses of CombinerAggregator in storm.trident.operation.impl

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

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

Uses of CombinerAggregator in storm.trident.state

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

Constructor and Description
CombinerValueUpdater(CombinerAggregator agg, Object arg)

Uses of CombinerAggregator in storm.trident.state.map

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

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