big-data/flink_book
1
1
Fork 0
Code Issues 4 Pull Requests Projects 1 Releases Wiki Activity

Flink SQL:时间区间Join

Browse Source
This commit is contained in:
LingZhaoHui 2023-04-05 22:50:37 +08:00
parent 13ecf2e663
commit fc609417cb
Signed by: zeekling
GPG Key ID: D96E4E75267CA2CC
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
Flink_SQL/时间区间Join.md
View File

@ -35,3 +35,12 @@ Join示例
函数processElement2 右流处理。
# 相关参数
`table.exec.source.idle-timeout`:
当一个source在超时时间内没有接收到任何元素时，它将被标记为临时空闲。这允许下游任务在空闲时提前其watermarks，而
无需等待来自该source的watermarks。