Class GroupedStream

java.lang.Object
org.apache.storm.trident.fluent.GroupedStream
All Implemented Interfaces:
GlobalAggregationScheme<GroupedStream>, IAggregatableStream

public class GroupedStream extends Object implements IAggregatableStream, GlobalAggregationScheme<GroupedStream>