Uses of Interface
org.apache.storm.trident.operation.Aggregator
-
-
Uses of Aggregator in org.apache.storm.trident
Methods in org.apache.storm.trident with parameters of type Aggregator Modifier and Type Method Description StreamStream. aggregate(Aggregator agg, Fields functionFields)StreamStream. aggregate(Fields inputFields, Aggregator agg, Fields functionFields)StreamStream. partitionAggregate(Aggregator agg, Fields functionFields)StreamStream. partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields)StreamStream. 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 everywindowCountof tuples and slides the window afterslideCount.StreamStream. 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 ofslidingIntervaland completes a window atwindowDuration.StreamStream. 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 everywindowCountof tuples.StreamStream. 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 ofwindowDuration.StreamStream. window(WindowConfig windowConfig, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, Fields functionFields)Returns stream of aggregated results based on the given window configuration.StreamStream. 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. -
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 Description ChainedFullAggregatorDeclarerChainedAggregatorDeclarer. aggregate(Aggregator agg, Fields functionFields)ChainedFullAggregatorDeclarerChainedAggregatorDeclarer. aggregate(Fields inputFields, Aggregator agg, Fields functionFields)ChainedFullAggregatorDeclarerChainedFullAggregatorDeclarer. aggregate(Aggregator agg, Fields functionFields)ChainedFullAggregatorDeclarerChainedFullAggregatorDeclarer. aggregate(Fields inputFields, Aggregator agg, Fields functionFields)StreamGroupedStream. aggregate(Aggregator agg, Fields functionFields)StreamGroupedStream. aggregate(Fields inputFields, Aggregator agg, Fields functionFields)ChainedPartitionAggregatorDeclarerChainedAggregatorDeclarer. partitionAggregate(Aggregator agg, Fields functionFields)ChainedPartitionAggregatorDeclarerChainedAggregatorDeclarer. partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields)ChainedPartitionAggregatorDeclarerChainedPartitionAggregatorDeclarer. partitionAggregate(Aggregator agg, Fields functionFields)ChainedPartitionAggregatorDeclarerChainedPartitionAggregatorDeclarer. partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields)IAggregatableStreamGroupedStream. partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields)IAggregatableStreamIAggregatableStream. 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 Description classBaseAggregator<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 Description classComparisonAggregator<T>AbstractAggregatorfor comparing two values in a stream.static classFirstN.FirstNAggstatic classFirstN.FirstNSortedAggclassMaxThis aggregator computes the maximum of aggregated tuples in a stream.classMaxWithComparator<T>This aggregator computes the maximum of aggregated tuples in a stream.classMinThis aggregator computes the minimum of aggregated tuples in a stream.classMinWithComparator<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 Description classChainedAggregatorImplclassCombinerAggregatorCombineImplclassGroupedAggregatorclassReducerAggregatorImplclassSingleEmitAggregatorConstructors in org.apache.storm.trident.operation.impl with parameters of type Aggregator Constructor 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 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 Description classCountAsAggregator -
Uses of Aggregator in org.apache.storm.trident.windowing
Fields in org.apache.storm.trident.windowing declared as Aggregator Modifier and Type Field Description protected AggregatorAbstractTridentWindowManager. aggregatorConstructors in org.apache.storm.trident.windowing with parameters of type Aggregator Constructor 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)
-