Uses of Interface
org.apache.storm.trident.fluent.IAggregatableStream
Packages that use IAggregatableStream
-
Uses of IAggregatableStream in org.apache.storm.trident
Classes in org.apache.storm.trident that implement IAggregatableStreamModifier and TypeClassDescriptionclassA Stream represents the core data model in Trident, and can be thought of as a "stream" of tuples that are processed as a series of small batches. -
Uses of IAggregatableStream in org.apache.storm.trident.fluent
Classes in org.apache.storm.trident.fluent with type parameters of type IAggregatableStreamModifier and TypeInterfaceDescriptioninterfaceGlobalAggregationScheme<S extends IAggregatableStream>Classes in org.apache.storm.trident.fluent that implement IAggregatableStreamMethods in org.apache.storm.trident.fluent that return IAggregatableStreamModifier and TypeMethodDescriptionGlobalAggregationScheme.aggPartition(S stream) GroupedStream.aggPartition(GroupedStream s) GroupedStream.partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields) IAggregatableStream.partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields) Constructors in org.apache.storm.trident.fluent with parameters of type IAggregatableStreamModifierConstructorDescriptionChainedAggregatorDeclarer(IAggregatableStream stream, GlobalAggregationScheme globalScheme)