Package org.apache.storm.trident.fluent

Interface ChainedAggregatorDeclarer.AggregationPartition

Enclosing class:
ChainedAggregatorDeclarer
public static interface ChainedAggregatorDeclarer.AggregationPartition

  • Method Summary

    Modifier and Type
    Method
    Description
    Stream
    partition(Stream input)