Aggregates the values in this stream using the aggregator. This does a global aggregation of values across all partitions. If the stream is windowed, the aggregate result is emitted after each window activation and represents the aggregate of elements that fall within that window. If the stream
(CombinerAggregator<? super T, A, ? extends R> aggregator)
| 193 | * @return the new stream |
| 194 | */ |
| 195 | public <A, R> Stream<R> aggregate(CombinerAggregator<? super T, A, ? extends R> aggregator) { |
| 196 | return combine(aggregator); |
| 197 | } |
| 198 | |
| 199 | /** |
| 200 | * Aggregates the values in this stream using the given initial value, accumulator and combiner. This does a global aggregation of |