Flink code example?

[nim-nim]

Hi,

Is the flink code used to process the result published somewhere? Probably not to use it as-is (our big data guys want to use spark not flink) but to get some ideas. The RIPE presentations are awfully nice (thank you so much for them) but actual code examples would be better.

[lspgn]

Hi @nim-nim, apologies for the delay in my response.
Thank you for looking at the presentation!
We ended up discarding Flink part as Clickhouse offers aggregations and the cluster was hard to maintain.
For everything that needs a more "live" aggregation: we turned to a Go program that inserts into Redis.
I still have the code and will publish it to the following repo in a few weeks.
I have not tried Spark though.

Good luck!