Package org.apache.storm.trident.fluent

# Interface GlobalAggregationScheme<S extends IAggregatableStream>

All Known Implementing Classes:
  `GroupedStream`

public interface GlobalAggregationScheme<S extends IAggregatableStream>

- ## Method Summary

  Modifier and Type
  Method
  Description
  `IAggregatableStream`
  `aggPartition(S stream)`
  `SingleEmitAggregator.BatchToPartition`
  `singleEmitPartitioner()`

- ## Method Details

  - ### aggPartition

    IAggregatableStream aggPartition(S stream)

  - ### singleEmitPartitioner

    SingleEmitAggregator.BatchToPartition singleEmitPartitioner()