I need to elaborate on my use case. I would like the SQL api to do
aggregation for me in an SQL TUMBLING window.
But I want the next window to perform business logic on all the
records just aggregated in a DataStream ProcessWindowFunction.
This would be a mix of SQL and DataStream API.
On Tue, Dec 8, 2020 at 1:29 PM Marco Villalobos
<
[hidden email]> wrote:
>
> GIVEN two windows (ProcessWindowFunction), window A, and window B,
> AND window A is a tumbling processing time window of 15 minutes
> AND 200000 records entered window A, and performs its business logic.
>
> How can I assure that Window B will process exactly all the records
> that left window A within the same window?
Locked
