阿里云文档 2023-01-09

与文字文档Table相关的API

本文介绍与文字文档Table相关的API。

问答 2022-02-15 来自:开发者社区

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

问答 2022-02-15 来自:开发者社区

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

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

产品推荐

AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等