Re: Unit testing for ProcessAllWindowFunction

2019-11-04 Thread vino yang
Hi Diogo, There is also a Scala version about AllWindowTranslationTest[1] which contains the example code snippet. [1]: https://github.com/apache/flink/blob/master/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/AllWindowTranslationTest.scala#L1644 Best, Vino Diogo Ara

Re: Unit testing for ProcessAllWindowFunction

2019-11-04 Thread Diogo Araújo
Even though your answer was helpful, I am testing my flink pipeline in scala not in java. Is there any Scala example you can provide me? Thanks in advance Diogo Araújo | Rockstar Developer diogo.ara...@criticaltechworks.com +351 912882824 Rua do Campo Alegre, nº 17, piso 0 | 4150-177 Porto www.c