George Theodorakis

Thank you for the comment. In the current version, we don't support a unified way of comparing the results and we do it manually. For example, in Flink, we collect...

Hi, 1) You could just change the parallelism and adjust properly the number of records per second. 2) If you redirect worker's output to the .out file, everything will be...

Hi, Unfortunately, I am away in an internship and I don't have much time to look at the code right now. The first thing that you have to keep in...

Hey Tony, this is a follow-up to the questions asked by @chenzongxiong (I've used some parts of his logic to implement my solution). I am trying to implement the YahooBenchmark...

Hi Tony, Thanks for the prompt response and help. You are right about the tumbling window representation. I will add the code/logic from Storm for handling them properly, but this...