Flink_batcher.sql

SELECT
  window_start,
  CEIL(row_num / 50.0) AS bundle, 
  COUNT(*), 
  AVG(value), 
  MAX(value), 
  MIN(value)
FROM (
  SELECT 
    *, 
    ROW_NUMBER() OVER (PARTITION BY window_start ORDER BY timestamp) as row_num
  FROM (
    SELECT 
      *, 
      TUMBLE_START(timestamp, INTERVAL '5' SECOND) as window_start
    FROM my_table
  )
) t
GROUP BY window_start, CEIL(row_num / 50.0)