Thank You Niels. Would you have something for the scala object class. Say for example if I want to implement a unit test ( not integration test) for below code or similar :
https://github.com/apache/flink/blob/master/flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/socket/SocketWindowWordCount.scala Regards, Vijay On Fri, Jul 31, 2020 at 12:22 PM Niels Basjes <ni...@basjes.nl> wrote: > Does this test in one of my own projects do what you are looking for? > > > https://github.com/nielsbasjes/yauaa/blob/1e1ceb85c507134614186e3e60952112a2daabff/udfs/flink/src/test/java/nl/basjes/parse/useragent/flink/TestUserAgentAnalysisMapperClass.java#L107 > > > On Fri, 31 Jul 2020, 20:20 Vijayendra Yadav, <contact....@gmail.com> > wrote: > >> Hi Team, >> >> Looking for some help and reference code / material to implement unit >> tests of possible scenarios in Flink *streaming *Code that should assert >> specific cases. >> >> Regards, >> Vijay >> >
