apache/rocketmq-streams

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

elenacliu opened this issue · 1 comments

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

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