Tumbling tables in the SQL API

Hi, In the SQL API I see the query below. I want to know how I can make tumbling tables based on amount of rows. So I want to make a window for row 1-10, 11-20 etc. It is also good if the windowing takes place on a Integer ID column. How can I do this? Table result1 = tableEnv.sqlQuery( "SE

How many events can Flink process each second

Hi, My boss wants to know how many events Flink can process, analyse etc. per second? I cant find this in the documentation.

Problem creating tumbling windows based on number of rows

Hi, I try to create a tumbling time window of 2 rows each in Flink Java. This must based on the dateTime (TimeStamp3 datatype) or unixDateTime(BIGINT datatype) column. I've added below the code of two different code versions. The error messages I get I placed above the code. When I print the