罗江宇

罗江宇

威望 : 1 积分 : 1060 赞同 : 4 感谢 : 0

擅长话题

更多 »回复

1

window比较小的区间比较适合,至于一天,还有区间不固定不太适合,可以考虑keyBy + processFunction, 通过flink 的状态来做计算

0

好的,这个后续上传一些这样的示例到github上

1

根据你的目前熟悉情况来选,针对flink 开发来说,scala 开发起来比较快,写起来比较简捷。这个具体选择还是根据你对语言的熟悉度。

0

这个我们整理下,到时候发到微信群里哈

1

flink保证exactly once 是体现在flink 系统内部,与其它组件(比如kafka, MQ,hdfs)联系,要保证exactly once, 需要其它组件提供一定的支持, 同时需要开启checkpoint ,配置好相应的参数。 具体connect...

更多 »发问

没有内容

发问

回复

文章

最新动态

详细资料

个人成就:

威望: 1 积分: 1060 赞同: 4 感谢: 0

最后活跃:
2018-04-12 19:38
擅长话题:
更多 » 关注 2

Dong 邹博

更多 » 2 人关注

小省 casel_chan

关注 0 话题
主页访问量 : 189 次访问