Uses of Interface
storm.trident.fluent.IAggregatableStream

Packages that use IAggregatableStream

Package	Description
storm.trident
storm.trident.fluent

Uses of IAggregatableStream in storm.trident

Classes in storm.trident that implement IAggregatableStream

Modifier and Type	Class and Description
class	Stream

Uses of IAggregatableStream in storm.trident.fluent

Classes in storm.trident.fluent with type parameters of type IAggregatableStream

Modifier and Type	Interface and Description
interface	GlobalAggregationScheme<S extends IAggregatableStream>

Classes in storm.trident.fluent that implement IAggregatableStream

Modifier and Type	Class and Description
class	GroupedStream

Methods in 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 storm.trident.fluent with parameters of type IAggregatableStream

Constructor and Description
ChainedAggregatorDeclarer(IAggregatableStream stream, GlobalAggregationScheme globalScheme)