Tumbling tables in the SQL API

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

Tumbling tables in the SQL API

A. V.
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(
  "SELECT user, " +
  "  TUMBLE_START(rowtime, INTERVAL '1' DAY) as wStart,  " +
  "  SUM(amount) FROM Orders " +
  "GROUP BY TUMBLE(rowtime, INTERVAL '1' DAY), user");


Thanks for the help.