Hi Diogo,
In order to test ProcessAllWindowFunction, you need to do a little more.
You can refer to Flink's own test code.[1]
In short:
1) Write a Flink Streaming job that uses your UDF (here is
ProcessAllWindowFunction) and return a DataStream.
2) Get OneInputTransformation through DataStream,
Good afternoon,
After Reading the official flink testing documentation
(https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/stream/testing.html)
I was able to develop tests for a ProcessFunction, using a Test Harness,
something like this:
pendingPartitionBuilder = new PendingParti
