Package org.apache.storm.trident.fluent
Interface IAggregatableStream
- All Known Implementing Classes:
- GroupedStream,- Stream
public interface IAggregatableStream
- 
Method SummaryModifier and TypeMethodDescriptionpartitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields) toStream()