Re: Representing Scala base types in the Flink RT

2015-01-21 Thread Stephan Ewen
Hi! The Basic types hold the Java primitives and their boxed versions. Since the "scala.Int" boils down to the Java int primitive type at runtime, they should be interoperable. I would guess that the problem is that "classOf[Int]" actually returns (in Java terms) "scala.Int.class", which is not r

Re: Representing Scala base types in the Flink RT

2015-01-20 Thread Alexander Alexandrov
Just to clarify in order to spare us some time in the discussion. I *deliberately* want to use Flink Java API from Scala with Scala core types. 2015-01-20 18:53 GMT+01:00 Alexander Alexandrov < alexander.s.alexand...@gmail.com>: > Hi there, > > I cannot figure out how the Scala base types (e.g. s