flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Chiwan Park <chiwanp...@apache.org>
Subject Re: returns method in scala api
Date Tue, 05 Apr 2016 05:14:59 GMT
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 <sewen@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 <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
View raw message