Interface StatefulAggregator<R,T>

All Superinterfaces:

Aggregator<R,T>

All Known Implementing Classes:

ExtremeValueAggregator, TreapAggregator, UpperCardinalitySumAggregator

public interface StatefulAggregator<R,T>
extends Aggregator<R,T>

Method Summary

Modifier and Type	Method	Description
default R	aggregateStream(Stream<T> stream)
StatefulAggregate<R,T>	createEmptyAggregate()
default R	getEmptyResult()

Methods inherited from interface Aggregator

getInputType, getResultType

Method Details

createEmptyAggregate

StatefulAggregate<R,T> createEmptyAggregate()

aggregateStream

@NotNull
default R aggregateStream(Stream<T> stream)

Specified by:

aggregateStream in interface Aggregator<R,T>

getEmptyResult

@NotNull
default R getEmptyResult()

Specified by:

getEmptyResult in interface Aggregator<R,T>