Flink中从API的角度来看，怎样去分配Timestamp或生成Watermark呢？
Flink中从API的角度来看，怎样去分配Timestamp或生成Watermark呢？
展开
收起
1
条回答
写回答
写回答
-
有两种方式：
第一种，在SourceFunction当中调用内部提供的 collectWithTimestamp方法，把包含时间戳的数据提取出来；还可以在SourceFunction中使用 emitWatermark方法去产生一个Watermark，然后插入到数据流中。
第二种，如果不在SourceFunction中可以调用DateStream.assignTimestampsAndWatermarks这个方法，同时传入两类Watermark生成器
2021-12-08 22:25:10赞同 展开评论 打赏
问答分类：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
