Scala API for flinkspector.

[lofifnc]

Provides integration with the Flink scala api and scala-test.
Uses scala test matchers instead of hamcrest.

[smandrell]

Hi,

I was wondering if there is any update on the Scala API for flinkspector? We are wondering how to test our flink-scala program and it seems like flinkspector is a good route. However, we do not know how to convert a Java DataStream to a Scala DataStream, so we we cannot get the original flinkspector API to work. Thanks!

[lofifnc]

Hi,

Unfortunately converting the DataStream from Java to Scala will not suffice because the Java Matchers do not work with most Scala data types.

I'm planning on porting the runtime and input api to work with scala. Big parts of the validation concepts are not compatible with the concepts of ScalaTest. So you would have to use the standart tools provided by ScalaTest which should be adequate for the most part.

At the moment it's hard for me to provide a timeframe because I wan't to fix a core issue of the framework first which has been bugging me for months.

Cheers!
Alex

[lofifnc]

The poc works. Now I will have to figure out which parts of the java api don't work with scala.