I’m trying to figure out when/why the AggregateFunction.merge() <https://ci.apache.org/projects/flink/flink-docs-release-1.4/api/java/org/apache/flink/api/common/functions/AggregateFunction.html#merge-ACC-ACC-> method is called in a streaming job, to ensure I’ve implemented it properly.
The documentation for AggregateFunction says "Merging intermediate aggregates (partial aggregates) means merging the accumulators.” But that sounds more like a combiner in batch processing, not streaming. From the code, it seems like this could be called if a MergingWindowAssigner is used, right? And is there any other situation in streaming where merge() could be called? Thanks, — Ken -------------------------------------------- http://about.me/kkrugler +1 530-210-6378
