DataStream[POJO]转table如何指定.rowtime字段?-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

DataStream[POJO]转table如何指定.rowtime字段?

2018-12-03 10:58:58 2760 1

click_info的类型是DataStream类型的;
image
Message我自己定义的POJO;
image
然后由DataStream转换为table的时候指定字段的代码如下:
image
转换为table之后在table上执行window算子操作
image
提交到集群之后一直报这个错:
image
问题:如何在DataStream[POJO]转换为表,表的schema中定义rowtime字段信息?定义rowtime字段信息后执行window算子将窗口alias 为W,在接下来的SQL查询中无法识别W,这个问题是怎么解决的?感谢大佬
在此基础上我对代码做了修改:
image
任务是跑起来了但是,文件下的size始终为0,没有输出
image
麻烦看下是哪出问题了,谢谢!

SQL
取消 提交回答
全部回答(1)
  • jark
    2019-07-17 23:18:04
    已采纳

    你的 rowtime 定义的没有问题,window 写法也没问题, alias 也没有问题。
    问题出在你在最后的 select 中,用了 over window 语法, 也就是 clicks.sum over w, impressions.sum over w。over Window 的语法,请参考 https://ci.apache.org/projects/flink/flink-docs-master/dev/table/sql.html 搜索 over window,

    如果只是想做 window aggregare, 直接 clicks.sum, impressions.sum即可。

    1 0
相关问答

0

回答

dataStream 如何做到像table api的upsert-kafka一样更新数据呢?

2022-08-24 16:58:51 87浏览量 回答数 0

0

回答

各位大佬 有没有遇到过这种场景 就是我cdc使用datastreamapi监控一个库下的所有表,

2022-07-22 13:48:24 101浏览量 回答数 0

0

回答

想问一下大佬,能用pyflink调用cdc的datastream api实现监控一个binlog同步

2022-06-24 13:43:32 116浏览量 回答数 0

1

回答

OC语言在运行期进行method swizzling,是通过怎样一个过程进行的?

2022-05-12 13:01:56 35浏览量 回答数 1

1

回答

Timestream      依赖什么?

2022-01-13 10:36:27 87浏览量 回答数 1

2

回答

mac下执行make命令编译OpenJdk8无法加载iostream,希望那位大神能给予解答,死等

2019-10-25 18:48:07 2111浏览量 回答数 2

2

回答

flink1.7.1 dataStream table API 的 distinc问题

2019-01-23 20:23:23 3341浏览量 回答数 2

1

回答

两个节点,ab a的时间线早于b,在a上执行pg_rewind去同步b不行吧?

2018-12-18 18:33:33 1413浏览量 回答数 1

0

回答

视频上传一直加载中,日志一直打印Shutting down reaper thread

2018-09-06 17:36:34 1951浏览量 回答数 0

1

回答

bootstrap table分页的问题,求大神帮忙

2016-07-07 13:33:43 1855浏览量 回答数 1
+关注
0
文章
5
问答
问答排行榜
最热
最新
相关电子书
更多
低代码开发师(初级)实战教程
立即下载
阿里巴巴DevOps 最佳实践手册
立即下载
冬季实战营第三期:MySQL数据库进阶实战
立即下载