Overview  Package   Class  Tree  Deprecated  Index  Help 
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

storm.trident.fluent
Interface GlobalAggregationScheme<S extends IAggregatableStream>

All Known Implementing Classes:
GroupedStream
public interface GlobalAggregationScheme<S extends IAggregatableStream>

Method Summary
 IAggregatableStream aggPartition(S stream)
           
 SingleEmitAggregator.BatchToPartition singleEmitPartitioner()
           
 

Method Detail

aggPartition

IAggregatableStream aggPartition(S stream)

singleEmitPartitioner

SingleEmitAggregator.BatchToPartition singleEmitPartitioner()
Overview  Package   Class  Tree  Deprecated  Index  Help 
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD