Dear Flink committers:
I am starting to learn implementing some data streaming algorithm based on Flink API. Now I am working on MisraGries algorithm. It keeps k counters to record the data summary by increment or decrement. I want to know what is the best approach to store those counters(a hashmap data structure maybe) when using DataStream API to implement the algorithm. Now I just declared a map variable in the operator, is it right or I need to use some other features like state. This may be a very basic question forgive me since I am just a beginnerT^T.
Best regards
------------------------------------------------------
Shengnan YU(於圣楠)
[hidden email]<mailto:
[hidden email]>
+852 69963058