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 and Description
class	Stream A 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 and Description
interface	GlobalAggregationScheme<S extends IAggregatableStream>

Classes in org.apache.storm.trident.fluent that implement IAggregatableStream

Modifier and Type	Class and Description
class	GroupedStream

Methods in org.apache.storm.trident.fluent that return IAggregatableStream

Modifier and Type	Method and Description
IAggregatableStream	GroupedStream.aggPartition(GroupedStream s)
IAggregatableStream	GlobalAggregationScheme.aggPartition(S stream)
IAggregatableStream	IAggregatableStream.each(Fields inputFields, Function function, Fields functionFields)
IAggregatableStream	GroupedStream.each(Fields inputFields, Function function, Fields functionFields)
IAggregatableStream	IAggregatableStream.partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields)
IAggregatableStream	GroupedStream.partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields)

Constructors in org.apache.storm.trident.fluent with parameters of type IAggregatableStream

Constructor and Description
ChainedAggregatorDeclarer(IAggregatableStream stream, GlobalAggregationScheme globalScheme)