用户组:游客
flink触发当前窗口计算的前提是下一条数据在当前窗口的结束时间之后,我现在想要实现一个功能是每进来一条数据都去统计当前窗口 ...
为什么一用JDBCAppendTableSink作为sink,MySQL就接不到数据呢。 换成继承RichSinkFunction类,就可以写入MySQL数据。
今天刚学到这,看视频有一个SQL语句中使用了自定义的function,但是没有讲解怎么添加jar到flink sql客户端。
一般在流式计算中都会有一个窗口的概念(window)。 比较在flink中的 .timeWindow(Time.seconds(5)) 它将无边界数据按时间划 ...
本版积分规则 发表帖子
查看 »