Package org.apache.storm.trident.fluent
Interface ChainedAggregatorDeclarer.AggregationPartition
-
- Enclosing class:
- ChainedAggregatorDeclarer
public static interface ChainedAggregatorDeclarer.AggregationPartition
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Stream
partition(Stream input)
-