1 2 3 4 5 6 7 8 9 10 11 12 13
package tools.refinery.store.query.term; import java.util.stream.Stream; public interface Aggregator<R, T> { Class<R> getResultType(); Class<T> getInputType(); R aggregateStream(Stream<T> stream); R getEmptyResult(); }