当前位置: 首页 > news >正文

Flink Temporal Join 系列 (2):用 Temporal Table DDL 实现基于处理时间的关联

本文要演示的是:使用 Temporal Table DDL 定义被关联表(维表),然后基于主动关联表(事实表)的“处理时间”去进行Temporal Join(关联时间维度上对应版本的维表数据)。该演示涉及三个要点:

  • 被关联的表(维表)是用 Temporal Table DDL 形式定义,必须是一张时态表(版本表)
  • 主动关联的表(事实表)需要定义“处理时间”属性,但并不需要是一张时态表(版本表)
  • Temporal Join 是使用 Temporal Table DDL + FOR SYSTEM_TIME AS OF 关键字实现的

测试结果会报如下错误:

[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.table.api.TableException: Processing-time temporal join is not supported yet.

文档所述一致,即:Flink 不支持使用 Temporal Table DDL 实现基于处理时间的 Temporal Join!此经该功能是支持的是,后因 FLINK-19830 描述的问题而在新版本中被禁止使用了。

-- 事实表: transactionsdrop table 
http://www.lryc.cn/news/325910.html

相关文章:

  • eclipse中使用PlantUML plugin查看对象关系
  • HCIP的学习(4)
  • MySQL写shell的问题
  • 每天学习一会java(第一天)----条件运算符
  • hyperf 二十八 修改器 一
  • ubuntu20.04安裝輸入法
  • 2024年【熔化焊接与热切割】考试报名及熔化焊接与热切割找解析
  • 聚类分析|基于层次的聚类方法及其Python实现
  • 前端实现导出xlsx功能
  • 算法系列--动态规划--⼦数组、⼦串系列(数组中连续的⼀段)(1)
  • RESTful架构
  • 从IO操作与多线程的思考到Redis-6.0
  • MNN介绍、安装和编译
  • 【计算机图形学】AO-Grasp: Articulated Object Grasp Generation
  • 「媒体宣传」财经类媒体邀约资源有哪些?-51媒体
  • 学习资料记录
  • 数据结构进阶篇 之 【二叉树】详细概念讲解(带你认识何为二叉树及其性质)
  • vue.js制作学习计划表案例
  • nginx localtion 匹配规则
  • Git:分布式版本控制系统
  • [STL]priority_queue类及反向迭代器的模拟实现
  • vue2 脚手架
  • 【OpenStack】OpenStack实战之开篇
  • Python实现WebSocket通信
  • MATLAB 自定义生成直线点云(详细介绍) (47)
  • UniTask 异步任务
  • 【git分支管理策略】如何高效的管理好代码版本
  • css的transition详解
  • agent利用知识来做规划:《KnowAgent: Knowledge-Augmented Planning for LLM-Based Agents》笔记
  • 01 React新建开发环境