I am sorry to task this twice. I reworded my question though, and I never got an answer. I am trying to learn how to use the SQL api, but mix-in the Streaming API where there is too much complex business logic.
GIVEN two windows, window X an SQL tumbling processing time window of 15 minutes, and window Y a ProcessFunction, AND 200000 records entered window X, and performs its business logic. How can I assure that Window Y will process exactly all the records that left window A within the same window? I am trying to do this: 200000 records streamed in --> SQL TUMBLING WINDOW --> aggregated table (the is results of table with 200000 records in it ) --> PROCESS FUNCTION (aggregated table)
