We need implementations for the following queries on Flink: - [ ] Yahoo Streaming Benchmark - [ ] NextMark Q4 - [ ] NextMark Q5 - [ ] NextMark Q7 - [ ] NextMark Q8