Hi Jiazhi,
I think an OVER window might solve your use case. It gives you a rolling
aggregation over period of time. Maybe you need to define a custom
aggregate function to emit the final record as you need it.
Let me know if you have further questions.
Regards,
Timo
On 27.01.21 15:02, ?g?
Hi all
After grouping by users, message A
arrives. If message B also arrives later, and the time of message B is less
than that of message A within 10 minutes, mark the field in message A with Tag
= True. How to achieve this?
Thanks
Jiazhi
Hi I have encountered a problem with Flink SQL.
My code:
DataSet dataSet0 = env.fromCollection( infos0 );
tableEnv.registerDataSet( "table0", dataSet0 );
String sql = "select closePrice from table0"
Table table = tableEnv.sql( sql );
tableEnv.registerTable( tableName, table );
