...
In our implementation, the operator will execute the MapPartitionFunction
while receiving records, rather than waiting for the entire window of records to be collected rather than waiting for the entire window of records to be collected. To achieve this, we add a seperate UDFExecutionThread inside the operator.
...