Hi Florian, big +1 for having more tests.
You can have a look at some testes for Flink processors [1], we use FlinkSpector here for testing stateless and stateful processors. There is no specific test framework for JVM-based processors, but I guess to properly test a pipeline element, this includes testing the controller + testing the runtime. For the controller, there are some convenience methods in [2] (but still a rather early stage) to create dummy schemas. We could add some methods there to create simulated event streams for better testing of the processor logic. Hope this helps! Dominik [1] https://github.com/apache/incubator-streampipes-extensions/blob/dev/streampipes-processors-transformation-flink/src/test/java/org/apache/streampipes/processors/transformation/flink/processor/hasher/TestFieldHasher.java [2] https://github.com/apache/incubator-streampipes/tree/dev/streampipes-test-utils On 2020/05/17 10:38:14, Florian Micklich <[email protected]> wrote: > Hi all, > > is there an existing example on how to write & perform unit tests in > StreamPipes? > > I would like to start to write tests for the geo operators. > > Greetings > Florian > >
