摘要：
两个概念 处理时间：流处理算子所在机器的本地时间。 事件时间：数据流中事件发生的实际时间，一般是附加在数据流中事件的时间戳。 watermark -- 事件时间窗口的触发时机 实际生产中，事件不可避免会产生延迟，如何判断某一时间点之前的事件都已接收到，从而触发流处理算子工作？Flink提供了水位线机 阅读全文
摘要：
1. 背景 在FlinkSQL关联时，必然会涉及到维表，维表又可能是不断变化的（aka 时态表 或 版本表）。 版本表: 如果时态表中的记录可以追踪和并访问它的历史版本，这种表a56爆大奖在线娱乐们称之为版本表，来自数据库的 changelog 可以定义成版本表。 普通表: 如果时态表中的记录仅仅可以追踪并和它的最新 阅读全文
摘要：
1. 背景 对FlinkSQL的聚合运算实践后select .. count(*) .. where .. group by ..，再对join关联做一些实践。 2. 代码 StreamExecutionEnvironment env = StreamExecutionEnvironment.get 阅读全文
摘要：
1. 背景 在测试FlinkSQL时，遇到FOR SYSTEM_TIME AS OF语法，研究下。 FOR SYSTEM_TIME AS OF otime指的是在otime时间点有效的数据。 2. 实践过程 时态数据库测试选择了SQL-server2017 -- 创建 时态表 -- DBO是a56爆大奖在线娱乐数据 阅读全文
摘要：
timestamp(3) a56爆大奖在线娱乐秒后3位小数，注意最多为6位。 create table test_timestamp( t1 timestamp(3) default now(3), t2 timestamp(4) default now(4), t3 timestamp(5) default no 阅读全文