flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "A. V." <aanvall...@live.nl>
Subject Tumbling tables in the SQL API
Date Fri, 25 Oct 2019 09:53:00 GMT

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.

View raw message