Hi Hequn,
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 wrote:
> Hi Austin,
>
> You can use GroupBy Window[1], such as TUMBLE Window. The size of t
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.
Best, Hequn
[1]
https://ci.apache.org/projects/flink/flink-docs-master/dev/table/ta
