Interface Aggregator<R,T>

All Known Subinterfaces:
StatefulAggregator<R,T>, StatelessAggregator<R,T>
All Known Implementing Classes:
ExtremeValueAggregator, IntSumAggregator, RealSumAggregator, UpperCardinalitySumAggregator

public interface Aggregator<R,T>
  • Method Details

    • getResultType

      Class<R> getResultType()
    • getInputType

      Class<T> getInputType()
    • aggregateStream

      @NotNull R aggregateStream(Stream<T> stream)
    • getEmptyResult

      @NotNull R getEmptyResult()