Uses of Interface
storm.trident.operation.Aggregator

Packages that use Aggregator

Package	Description
storm.trident
storm.trident.fluent
storm.trident.operation
storm.trident.operation.builtin
storm.trident.operation.impl
storm.trident.planner.processor
storm.trident.testing

Uses of Aggregator in storm.trident

Methods in storm.trident with parameters of type Aggregator

Modifier and Type	Method and Description
Stream	Stream.aggregate(Aggregator agg, Fields functionFields)
Stream	Stream.aggregate(Fields inputFields, Aggregator agg, Fields functionFields)
Stream	Stream.partitionAggregate(Aggregator agg, Fields functionFields)
Stream	Stream.partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields)

Uses of Aggregator in storm.trident.fluent

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

Modifier and Type	Method and Description
Stream	GroupedStream.aggregate(Aggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	ChainedAggregatorDeclarer.aggregate(Aggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	ChainedFullAggregatorDeclarer.aggregate(Aggregator agg, Fields functionFields)
Stream	GroupedStream.aggregate(Fields inputFields, Aggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	ChainedAggregatorDeclarer.aggregate(Fields inputFields, Aggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	ChainedFullAggregatorDeclarer.aggregate(Fields inputFields, Aggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedPartitionAggregatorDeclarer.partitionAggregate(Aggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedAggregatorDeclarer.partitionAggregate(Aggregator agg, Fields functionFields)
IAggregatableStream	IAggregatableStream.partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields)
IAggregatableStream	GroupedStream.partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedPartitionAggregatorDeclarer.partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedAggregatorDeclarer.partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields)

Uses of Aggregator in storm.trident.operation

Classes in storm.trident.operation that implement Aggregator

Modifier and Type	Class and Description
class	BaseAggregator<T>

Uses of Aggregator in storm.trident.operation.builtin

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

Modifier and Type	Class and Description
static class	FirstN.FirstNAgg
static class	FirstN.FirstNSortedAgg

Uses of Aggregator in storm.trident.operation.impl

Classes in storm.trident.operation.impl that implement Aggregator

Modifier and Type	Class and Description
class	ChainedAggregatorImpl
class	CombinerAggregatorCombineImpl
class	GroupedAggregator
class	ReducerAggregatorImpl
class	SingleEmitAggregator

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

Constructor and Description
ChainedAggregatorImpl(Aggregator[] aggs, Fields[] inputFields, ComboList.Factory fact)
GroupedAggregator(Aggregator agg, Fields group, Fields input, int outSize)
SingleEmitAggregator(Aggregator agg, SingleEmitAggregator.BatchToPartition batchToPartition)

Uses of Aggregator in storm.trident.planner.processor

Constructors in storm.trident.planner.processor with parameters of type Aggregator

Constructor and Description
AggregateProcessor(Fields inputFields, Aggregator agg)

Uses of Aggregator in storm.trident.testing

Classes in storm.trident.testing that implement Aggregator

Modifier and Type	Class and Description
class	CountAsAggregator