Hi folks, I am new to Flink will appropriate any guidance in my learning. I am looking at implementing a ranking function using Flink within a fixed window (Tumbling Window?) to mimic the functionality of foreachbatch in spark streaming. the original code in Spark looks like this: ROW_NUMBER() OVER (Partition by ID order by sequencenumber) I have digging hard to find a solution template but haven't find one yet, any help will be much appreciated.