Question about Writing Incremental Graph Algorithms using Apache Flink Gelly

Hi all, As I stated in the post here (https://stackoverflow.com/questions/61164302/writing-incremental-graph-algorithms-using-apache-flink-gelly ), I am trying to write a dynamic algorith

Re: TypeInformation composition ?

Thanks a lot! On Sat, 11 Apr 2020 at 20:45, Seth Wiesman 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 1

Re: TypeInformation composition ?

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 > wrote: > >  > Hello, > > I have a

TypeInformation composition ?

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

Re: Setting different idleStateRetentionTime for different queries executed in the same TableEnvironment in Flink 1.10

Yes, that's right. Set idleStateRetentionTime on TableConfig before translation should work. On Sat, 11 Apr 2020 at 14:46, Jiahui Jiang wrote: > Thank you for answering! I was reading > StreamExecutionEnvironmentImpl/StreamPlanner, and it seems to me that when > trying to convert tables to DataS