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

Packages that use Aggregator

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

Uses of Aggregator in org.apache.storm.trident

Methods in org.apache.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)
Stream	Stream.slidingWindow(BaseWindowedBolt.Duration windowDuration, BaseWindowedBolt.Duration slidingInterval, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, Fields functionFields) Returns a stream of tuples which are aggregated results of a window which slides at duration of slidingInterval and completes a window at windowDuration.
Stream	Stream.slidingWindow(int windowCount, int slideCount, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, Fields functionFields) Returns a stream of tuples which are aggregated results of a sliding window with every windowCount of tuples and slides the window after slideCount.
Stream	Stream.tumblingWindow(BaseWindowedBolt.Duration windowDuration, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, Fields functionFields) Returns a stream of tuples which are aggregated results of a window that tumbles at duration of windowDuration.
Stream	Stream.tumblingWindow(int windowCount, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, Fields functionFields) Returns a stream of tuples which are aggregated results of a tumbling window with every windowCount of tuples.
Stream	Stream.window(WindowConfig windowConfig, Fields inputFields, Aggregator aggregator, Fields functionFields) Returns a stream of aggregated results based on the given window configuration which uses inmemory windowing tuple store.
Stream	Stream.window(WindowConfig windowConfig, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, Fields functionFields) Returns stream of aggregated results based on the given window configuration.

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

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

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

Uses of Aggregator in org.apache.storm.trident.operation

Classes in org.apache.storm.trident.operation that implement Aggregator

Modifier and Type	Class and Description
class	BaseAggregator<T>

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

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

Modifier and Type	Class and Description
class	ComparisonAggregator<T> Abstract Aggregator for comparing two values in a stream.
static class	FirstN.FirstNAgg
static class	FirstN.FirstNSortedAgg
class	Max This aggregator computes the maximum of aggregated tuples in a stream.
class	MaxWithComparator<T> This aggregator computes the maximum of aggregated tuples in a stream.
class	Min This aggregator computes the minimum of aggregated tuples in a stream.
class	MinWithComparator<T> This aggregator computes the minimum of aggregated tuples in a stream.

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

Classes in org.apache.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 org.apache.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 org.apache.storm.trident.planner.processor

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

Constructor and Description
AggregateProcessor(Fields inputFields, Aggregator agg)

Uses of Aggregator in org.apache.storm.trident.testing

Classes in org.apache.storm.trident.testing that implement Aggregator

Modifier and Type	Class and Description
class	CountAsAggregator

Uses of Aggregator in org.apache.storm.trident.windowing

Fields in org.apache.storm.trident.windowing declared as Aggregator

Modifier and Type	Field and Description
protected Aggregator	AbstractTridentWindowManager.aggregator

Constructors in org.apache.storm.trident.windowing with parameters of type Aggregator

Constructor and Description
AbstractTridentWindowManager(WindowConfig windowConfig, String windowTaskId, WindowsStore windowStore, Aggregator aggregator, BatchOutputCollector delegateCollector)
InMemoryTridentWindowManager(WindowConfig windowConfig, String windowTaskId, WindowsStore windowStore, Aggregator aggregator, BatchOutputCollector delegateCollector)
StoreBasedTridentWindowManager(WindowConfig windowConfig, String windowTaskId, WindowsStore windowStore, Aggregator aggregator, BatchOutputCollector delegateCollector, Long maxTuplesCacheSize, Fields inputFields)
WindowTridentProcessor(WindowConfig windowConfig, String uniqueWindowId, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, boolean storeTuplesInStore)