Note that you should use `createTypeInfomation[T]` method in `org.apache.flink.api.scala` package object to create `TypeInformation` for Scala specific types such as case classes or tuples.
Regards, Chiwan Park > On Apr 5, 2016, at 1:53 AM, Stephan Ewen <se...@apache.org> wrote: > > Hi! > > In Scala, the return TypeInformation is passed as an implicit parameter. > You can always explicitly pass an implicit parameter, that would be the way > to pass the return type explicitly in Scala. > > To create the TypeInformation, use the TypeInformation.of(...) methods. > > Hope that helps! > > Stephan > > > > On Mon, Apr 4, 2016 at 3:08 PM, Judit Fehér <feh...@gmail.com> wrote: > >> Hi, >> >> I'm writing a custom serializer so I need to call the >> returns(TypeInformation) method after a reduce method, but it isn't >> available in the scala api, only in the java api. >> Do you have any suggestions how to go around this and still call the >> correct deserializer? >> Thanks! >> >> Judit >>
