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