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
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	Description
interface	GlobalAggregationScheme<S extends IAggregatableStream>

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

Modifier and Type	Class	Description
class	GroupedStream

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

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

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

Modifier	Constructor	Description
	ChainedAggregatorDeclarer(IAggregatableStream stream, GlobalAggregationScheme globalScheme)