flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stephan Ewen <se...@apache.org>
Subject Re: returns method in scala api
Date Mon, 04 Apr 2016 16:53:34 GMT
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 <feherj@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
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message