完整SQL代码

https://gitee.com/appleyuchi/Flink_Code/blob/master/flink-sql-cookbook/SQL/Interval_Joins.sql

基本概念

TIMESTAMPDIFF的作用

mysql> select TIMESTAMPDIFF(DAY, '2018-03-20 23:59:00', '2015-03-22 00:00:00');
+------------------------------------------------------------------+
| TIMESTAMPDIFF(DAY, '2018-03-20 23:59:00', '2015-03-22 00:00:00') |
+------------------------------------------------------------------+
|                                                            -1094 |
+------------------------------------------------------------------+

意思是:

2015年的某天-2018年的某天＝天数差是-1094天

另外，上述SQL中涉及的订单表和发货表都是数据更新很快的表格．

所以这两张表都属于事实表．

此例属于两个事实表进行Join操作．

Interval Join查询语句

SELECTo.id AS order_id,o.order_time,s.shipment_time,TIMESTAMPDIFF(DAY,o.order_time,s.shipment_time) AS day_diff
FROM orders o
JOIN shipments s ON o.id = s.order_id
WHERE o.order_time BETWEEN s.shipment_time - INTERVAL '3' DAY AND s.shipment_time;

上述SQL语句的含义是:

SQL语句部分	业务含义
o.id AS order_id	订单ID
o.order_time	下单时间
s.shipment_time	发货时间
TIMESTAMPDIFF(DAY,o.order_time,s.shipment_time)	发货时间与下单时间的差
FROM orders o JOIN shipments s ON o.id = s.order_id	两张表(orders与shipments)中下单ID等于发货ID的数据
o.order_time BETWEEN s.shipment_time - INTERVAL '3' DAY AND s.shipment_time;	计算下单后3天内发货的订单

上述最后一部分的图解如下:

上面的图被误伤，下面的图是重新画的。

这个图的意思是：

查询下单后3天内发货的订单。

flink sql实现interval join的图解相关推荐

Flink SQL之Interval Joins
1.Interval Joins(区间Join) 区间是双流join的优化,基于处理时间或事件时间,在一定时间区间内数据,相同的key进行join(支持 Batch\Streaming).Interv ...
Flink SQL解析复杂Join(转载+自己整理和补充)
概述 $KAFKA/bin/kafka-console-consumer.sh --bootstrap-server Desktop:9091 --from-beginning --topic zep ...
flink sql 知其所以然（十五）：改了改源码，实现了个 batch lookup join（附源码）
看了那么多的技术文,你能明白作者想让你在读完文章后学到什么吗? 大数据羊说__的文章会让你明白大数据羊说用数据提升美好事物发生的概率~ 44篇原创内容公众号博主会阐明博主期望本文能给小伙伴们带 ...
Flink SQL 功能解密系列 —— 维表 JOIN 与异步优化
2019独角兽企业重金招聘Python工程师标准>>> 引子流计算中一个常见的需求就是为数据流补齐字段.因为数据采集端采集到的数据往往比较有限,在做数据分析之前,就要先将所需的维度 ...
Flink SQL 1.11 新功能与最佳实践
#2020云栖大会#阿里云海量offer来啦!投简历.赢阿里云限量礼品及阿里云ACA认证免费考试资格!>>> 整理者:陈婧敏(清樾) 本文整理自 Apache Flink PMC,阿 ...
Flink SQL 1.11新功能详解：Hive 数仓实时化 Flink SQL + CDC 实践
问题导读 1.Flink 1.11 有哪些新功能? 2.如何使用 flink-cdc-connectors 捕获 MySQL 和 Postgres 的数据变更? 3.怎样利用 Flink SQL 做多 ...
flink sql 知其所以然（十三）：流 join 很难嘛？（下）
看了那么多的技术文,你能明白作者想让你在读完文章后学到什么吗? 大数据羊说__的文章会让你明白大数据羊说用数据提升美好事物发生的概率~ 43篇原创内容公众号博主会阐明博主期望本文能给小伙伴们带 ...
Flink SQL 如何实现数据流的 Join？
无论在 OLAP 还是 OLTP 领域,Join 都是业务常会涉及到且优化规则比较复杂的 SQL 语句.对于离线计算而言,经过数据库领域多年的积累,Join 语义以及实现已经十分成熟,然而对于近年来刚 ...
Flink SQL Client中的session window图解
flink sql cookbook中的sql语句是: SELECT userid,SESSION_START(log_time, INTERVAL '10' SECOND) AS session_b ...

flink sql实现interval join的图解

完整SQL代码

基本概念

Interval Join查询语句

flink sql实现interval join的图解相关推荐

最新文章

热门文章