No, I only have Java. On Fri, 31 Jul 2020, 21:57 Vijayendra Yadav, <contact....@gmail.com> wrote:
> 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 >>> >>
