Re: State & Generics

2020-04-05 Thread Laurent Exsteens
Hi Aljoscha, Thank you for your answer! Out of curiosity, would writing my own serializer involve implementing a serialisation for every your I could get? On Wed, Apr 1, 2020, 13:57 Aljoscha Krettek wrote: > Hi Laurent! > > On 31.03.20 10:43, Laurent Exsteens wrote: > > Yesterday I managed to

Re: State & Generics

2020-04-01 Thread Aljoscha Krettek
Hi Laurent! On 31.03.20 10:43, Laurent Exsteens wrote: Yesterday I managed to find another solution: create the type information outside of the class and pass it to the constructor. I can retrieve the type information from DataStream.getType() (whiich. This works well, and is acceptable in my ca

Re: State & Generics

2020-03-31 Thread Laurent Exsteens
Hello Mike, thanks for the info. I tried to do sth similar in Java. Not there yet but I think that should be feasible. However, like you said, that means additional operations for each event. Yesterday I managed to find another solution: create the type information outside of the class and pass

Re: State & Generics

2020-03-29 Thread Mike Mintz
I was able to get generic types to work when I used GenericTypeInfo and made sure to wrap the generic in some concrete type. In my case I used scala.Some as the wrapper. It looks something like this (in Scala): import org.apache.flink.api.java.typeutils.GenericTypeInfo val descriptor = new ListSta