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....
本页面内关键词为智能算法引擎基于机器学习所生成，如有任何问题，可在页面下方点击"联系我们"与我们沟通。
