Interface Aggregator<R,T>

All Known Subinterfaces:

StatefulAggregator<R,T>, StatelessAggregator<R,T>

All Known Implementing Classes:

ExtremeValueAggregator, IntSumAggregator, TreapAggregator, UpperCardinalitySumAggregator

public interface Aggregator<R,T>

Method Summary

Modifier and Type	Method	Description
R	aggregateStream(Stream<T> stream)
R	getEmptyResult()
Class<T>	getInputType()
Class<R>	getResultType()

Method Details

getResultType

Class<R> getResultType()

getInputType

Class<T> getInputType()

aggregateStream

@NotNull
R aggregateStream(Stream<T> stream)

getEmptyResult

@NotNull
R getEmptyResult()