Uses of Interface
org.apache.storm.trident.fluent.IAggregatableStream
-
Uses of IAggregatableStream in org.apache.storm.trident
Modifier and TypeClassDescriptionclass
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
Modifier and TypeInterfaceDescriptioninterface
GlobalAggregationScheme<S extends IAggregatableStream>
Modifier 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) ModifierConstructorDescriptionChainedAggregatorDeclarer
(IAggregatableStream stream, GlobalAggregationScheme globalScheme)