1
条回答
写回答
写回答
-
开发者社区问答官方账号官方回答采纳回答延迟曲线是说明数据发生时间与数据离开 Flink Source 的时间之间的差值，而非代表离开Source后的处理时间。SQL的计算方案为在源表上定义对应数据的系统时间字段，process time等，在逻辑的最终，Insert into的时候添加系统当前时间，可使用 TIMESTAMPDIFF(timepointunit, timepoint1, timepoint2)函数来计算差值，该函数含义为 返回 timepoint1 和 timepoint2 之间时间间隔。间隔的单位由第一个参数给出，它应该是以下值之一： SECOND，MINUTE，HOUR，DAY，MONTH 或 YEAR。
insert into时示例：
insert into TableName select TIMESTAMPDIFF( SECOND, CURRENT_TIMESTAMP, `time`) from SourceTableName;
注：`time`为上游源表中定义的系统时间字段。2024-06-13 18:05:47赞同 展开评论 打赏
问答分类：
关联地址：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
