flink1.11 流式读取hive怎么设置 process_time 和event_time?
flink1.11 流式读取hive怎么设置 process_time 和event_time?
Event time 是通过 DDL 中 watermark 语句设置的，具体可以参考文档 [1] [1] https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/sql/create.html#create-table <">https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/sql/create.html#create-table> Best, Dan Zou > 2020年8月30日 下午9:42，me me...@lishiyu.cn 写道： > > flink1.11 可以使用在使用select语句时，显式的指定是流式读取，流式的读出出来之后如果想使用实时计算中的特性窗口函数然后指定时间语义 事件时间和处理时间，但是flink sql需要显示的定义数据中的时间字段才能识别为 event_time，求问这个怎么去设置。*来自志愿者整理的flink邮件归档
写回答
-
可以尝试下立刻语句是否可行 https://ci.apache.org/projects/flink/flink-docs-master/dev/table/sql/create.html#create-table
CREATE TABLE Orders ( user BIGINT, product STRING, order_time TIMESTAMP(3) ) WITH ( 'connector' = 'kafka', 'scan.startup.mode' = 'earliest-offset' );
CREATE TABLE Orders_with_watermark ( -- Add watermark definition WATERMARK FOR order_time AS order_time - INTERVAL '5' SECOND ) WITH ( -- Overwrite the startup-mode 'scan.startup.mode' = 'latest-offset' )*来自志愿者整理的flink
2021-12-07 20:18:04赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关课程
更多
相关文章
相关电子书
更多
