Flink Temporal Join 系列 (3)：用 Temporal Table Function 实现基于事件时间的关联

作者：小蓝xlanll | 2024-04-09 16:44:29

踩

本文要演示的是：使用 Temporal Table Function 定义被关联表（维表），然后基于主动关联表（事实表）的“事件时间”去进行Temporal Join（关联时间维度上对应版本的维表数据）。

本文实现的效果与《Flink Temporal Join 系列 (1)：用 Temporal Table DDL 实现基于事件时间的关联》一文完全等同，但时态表是通过 Temporal Table Function 实现的。该演示同样涉及三个要点：

由于目前 Temporal Table Function 还不能在 SQL 中注册，所以，只能改为使用 Table API 在 Java 程序代码中完成演示：

package com.github.flink.examples

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/小蓝xlanll/article/detail/394018