Table api 中指定rowtime的问题
当我把DataStream流转成Table,并且指定了rowtime,然后使用带有udtf的sql传入tableEnv.sql(),抛出如下错误:Rowtime attributes must not be in the input rows of a regular join. As a workaround you can ...
Flink Table / SQL API:在会话窗口聚合后修改rowtime属性
是否可以rowtime在第一次session聚合后修改属性,使其等于.rowtime会话中最后一次观察到的事件?我正在尝试做这样的事情:table .window(Session withGap 2.minutes on 'rowtime as 'w) .groupBy('w, 'userId) .select('userId, ('w.end.cast(Types.LONG) - 'w....
本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。