Hi, I am trying to calculate the top k element based on a streaming aggregation per window. Do you know if there is any support for it on BeamSQL or How can achieve this goal with BeamSQL on stream ?
Sample Query SELECT customer_id, app, sum(bytes_total) as bytes_total FROM PCOLLECTION GROUP BY customer_id, app, TUMBLE(log_time, INTERVAL '1' MINUTE) ORDER BY bytes_total DESC LIMIT 10 Thanks
