search

apache / rocketmq-streams

Apache rocketmq
https://rocketmq.apache.org/
Apache License 2.0
171 stars 82 forks source link

what's the difference between `AccumulatorSupplier.java` and `AggregateSupplier.java`? #298

Closed elenacliu closed 1 year ago

elenacliu commented 1 year ago

I'm wondering the difference between AccumulatorSupplier.java and AggregateSupplier.java, because it seems that AggregateSupplier.java can do what AccumulatorSupplier.java do.

ni-ze commented 1 year ago

The different is the param of construction: Accumulator separate the adding data from getting the aggregate result. It has two phase.