Re: [Flink::Test] access registered accumulators via harness

2020-10-30 Thread Sharipov, Rinat
Hi Dawid, thx for your reply and sorry for a question with a double interpretation ! You understood me correctly, I would like to get counters value by their names after completing all operations with the harness component. I suppose that it should be useful because most of our functions are impl

Re: [Flink::Test] access registered accumulators via harness

2020-10-30 Thread Dawid Wysakowicz
Hi Rinat, First of all, sorry for some nitpicking in the beginning, but your message might be a bit misleading for some. If I understood your message correctly you are referring to Metrics, not accumulators, which are a different concept[1]. Or were you indeed referring to accumulators? Now on to

[Flink::Test] access registered accumulators via harness

2020-10-27 Thread Sharipov, Rinat
Hi mates ! I guess that I'm doing something wrong, but I couldn't find a way to access registered accumulators and their values via *org.apache.flink.streaming.util.**ProcessFunctionTestHarness *function wrapper that I'm using to test my functions. During the code research I've found, that requir