Flink SQL:时间区间Join

Flink_SQL/README.md

@@ -2,5 +2,6 @@
 <a title="Hits" target="_blank" href="https://github.com/zeekling/hits"><img src="https://hits.b3log.org/zeekling/flink_book.svg"></a></p>
 
 - [双流Join底层原理](./双流Join底层原理.md)
+- [时间区间Join](./时间区间Join.md)
 
 

Flink_SQL/时间区间Join.md

@@ -0,0 +1,18 @@
+
+# 简介
+
+时间区间Join语法：
+
+![时间区间Join](https://pan.zeekling.cn/flink/akka/%E6%97%B6%E9%97%B4%E5%8C%BA%E9%97%B4join_001.png)
+
+上图只能Join前后十分钟的数据。
+
+![Join结果](https://pan.zeekling.cn/flink/akka/%E6%97%B6%E9%97%B4%E5%8C%BA%E9%97%B4join_002.png)
+
+如上图所示，表payment_flow中09:50的数据只能和表user_order中09:40到10:00之间的数据做时间区间Join。不在这个时间
+区间内的数据关联不上。
+
+# 执行流程
+
+
+

README.md

@@ -37,13 +37,14 @@ Flink SQL学习笔记提纲。持续更新。Hive SQL 离线Join VS Flink SQL
 ## 目录
 
 - [Flink SQL双流Join底层原理](./Flink_SQL/双流Join底层原理.md)
+- [时间区间Join](./Flink_SQL/时间区间Join.md)
 
 # Flink 源码
 
 源码编译可以使用下面命令
 
 ```sh
-mvn install -DskipTests -Dfast -Dpmd.skip=true -Dcheckstyle.skip=true -Dmaven.javadoc.skip=true -Dmaven.compile.fork=true -Pskip-webui-build
+mvn install -DskipTests -Dfast -Dpmd.skip=true -Dcheckstyle.skip=true -Dmaven.javadoc.skip=true -Dmaven.compile.fork=true
 
 ```
 

source_code/README.md

@@ -3,5 +3,5 @@
 - [per-job模式启动分析](./per-job启动.md)
 - [application启动分析](./application启动.md)
 - [yarn-session启动分析](./yarn-session启动.md)
-
+- [Flink通信原理](./Flink组件通信.md)