If the type information for T is stored in a member variable called myTypeInfo 
you can do something like this.

import org.apache.flink.api.common.typeinfo.Types;

Types.TUPLE(Types.LONG, myTypeInfo);

Seth 

> On Apr 11, 2020, at 11:06 AM, Laurent Exsteens <laurent.exste...@euranova.eu> 
> wrote:
> 
> 
> Hello,
> 
> I have a generic ProcessFunction using list state, for which I receive the 
> type information as constructor parameter (since it is not possible to create 
> the type information in the class due to type Erasure).
> 
> I now need to keep not only the data, but also the timestamp at which they 
> appear. But I don't find a way to create a list state of Tuple2<long, T> 
> (where T is the generic type, for which I receive the type information as 
> parameter.
> 
> I would like to create that state descriptor getting only those informations 
> (in order to keep the interface of the class simple.
> 
> Right now I manage by creating 2 state: one for T and one for Long.
> 
> But I wonder if I could create that composite state,. For exemple n'y 
> composing the type informations, but I didn't find a way to do that.
> 
> Any other idea is also welcome.
> 
> Thanks in advance.
> 
> Regards,
> 
> Laurent.
> 
> ♻ Be green, keep it on the screen

Reply via email to