flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Basanth Gowda <basanth.go...@gmail.com>
Subject Aggregation on multiple Key combinations and multiple Windows
Date Mon, 14 Aug 2017 12:03:05 GMT
Posted this yesterday, but not sure if it went through or not.

I am fairly new to Flink. I have a use case which needs aggregation on
different combination of keys and windowing for different intervals. I
searched through but couldn't find anything that could help.

Came across this model on a presentation for Apex . This sums up what we
are trying to achieve. What is the best way to do this in Flink


I have been able to do this by the following and repeating this for every
key + window combination. So in the above case there would be 8 blocks like
below. (4 combinations and 2 window period for each combination)


View raw message