flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Laurent Exsteens <laurent.exste...@euranova.eu>
Subject Re: TypeInformation composition ?
Date Sat, 11 Apr 2020 21:58:46 GMT
Thanks a lot!

On Sat, 11 Apr 2020 at 20:45, Seth Wiesman <sjwiesman@gmail.com> wrote:

> 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.exsteens@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
>
>

-- 
*Laurent Exsteens*
Data Engineer
(M) +32 (0) 486 20 48 36

*EURA NOVA*

Rue Emile Francqui, 4

1435 Mont-Saint-Guibert

(T) +32 10 75 02 00

*euranova.eu <http://euranova.eu/>*

*research.euranova.eu* <http://research.euranova.eu/>

-- 
♻ Be green, keep it on the screen

Mime
View raw message