Package org.apache.storm.trident.fluent

# Interface IAggregatableStream

All Known Implementing Classes:
  `GroupedStream`, `Stream`

public interface IAggregatableStream

- ## Method Summary

  Modifier and Type
  Method
  Description
  `IAggregatableStream`
  `each(Fields inputFields, Function function, Fields functionFields)`
  `Fields`
  `getOutputFields()`
  `IAggregatableStream`
  `partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields)`
  `Stream`
  `toStream()`

- ## Method Details

  - ### each

    IAggregatableStream each(Fields inputFields, Function function, Fields functionFields)

  - ### partitionAggregate

    IAggregatableStream partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields)

  - ### toStream

    Stream toStream()

  - ### getOutputFields

    Fields getOutputFields()