storm.trident.fluent
Interface ChainedAggregatorDeclarer.AggregationPartition

Enclosing class:
ChainedAggregatorDeclarer

public static interface ChainedAggregatorDeclarer.AggregationPartition


Method Summary
 Stream partition(Stream input)
           
 

Method Detail

partition

Stream partition(Stream input)