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
