You can use GroupBy Window[1], such as TUMBLE Window. The size of the window either as time or row-count interval. You can also define your own User-Defined Aggregate Functions[2] to be used in window.
Thank you for the info! Much appreciated! Do you know if a GroupBy Window could be used to buffer until an arbitrary record came through?
Best,
Austin
On Thu, Oct 25, 2018, 9:17 PM Hequn Cheng <[hidden email]> wrote:
Hi Austin,
You can use GroupBy Window[1], such as TUMBLE Window. The size of the window either as time or row-count interval. You can also define your own User-Defined Aggregate Functions[2] to be used in window.