Uses of Interface
org.apache.storm.trident.fluent.IAggregatableStream
-
Packages that use IAggregatableStream Package Description org.apache.storm.trident org.apache.storm.trident.fluent -
-
Uses of IAggregatableStream in org.apache.storm.trident
Classes in org.apache.storm.trident that implement IAggregatableStream Modifier and Type Class Description classStreamA 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 IAggregatableStream Modifier and Type Interface Description interfaceGlobalAggregationScheme<S extends IAggregatableStream>Classes in org.apache.storm.trident.fluent that implement IAggregatableStream Modifier and Type Class Description classGroupedStreamMethods in org.apache.storm.trident.fluent that return IAggregatableStream Modifier and Type Method Description IAggregatableStreamGlobalAggregationScheme. aggPartition(S stream)IAggregatableStreamGroupedStream. aggPartition(GroupedStream s)IAggregatableStreamGroupedStream. each(Fields inputFields, Function function, Fields functionFields)IAggregatableStreamIAggregatableStream. each(Fields inputFields, Function function, Fields functionFields)IAggregatableStreamGroupedStream. partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields)IAggregatableStreamIAggregatableStream. partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields)Constructors in org.apache.storm.trident.fluent with parameters of type IAggregatableStream Constructor Description ChainedAggregatorDeclarer(IAggregatableStream stream, GlobalAggregationScheme globalScheme)
-