Flink SQL技术咨询：能否在临时视图上实现Temporal Join？

1. 能否为临时视图设置主键？ #

Flink SQL中临时视图本身没有物理主键，但可以通过显式声明让优化器识别主键语义，具体有两种可行方式：

• 显式声明主键（Flink 1.14及以上版本支持）
  创建视图时直接指定主键，语法示例：

  CREATE TEMPORARY VIEW view_name
  AS SELECT id, name, price FROM source_table
  PRIMARY KEY (id) NOT ENFORCED;
  

  其中NOT ENFORCED表示Flink不会校验主键唯一性，仅告知优化器主键信息，依赖上游表保证主键约束。
• 依赖上游主键推导
  若视图基于带主键的upsert-kafka表（本身是版本化变更流）创建，且SELECT语句保留了原表主键字段，优化器可自动推导主键信息，但显式声明的方式更可靠。

2. 能否在临时视图上执行Temporal Join？ #

可以，但需满足两个核心前提：

• 临时视图需被识别为版本化表：视图底层数据必须是带主键的变更流（如来自upsert-kafka的UPSERT/DELETE事件），且已通过上述方式声明或推导出主键。
• 视图数据流符合版本表要求：主键对应的记录随时间更新，能提供任意时间点的快照数据。

满足条件后即可执行Temporal Join，示例如下（假设dim_user_view已声明主键user_id）：

SELECT
  o.order_id,
  o.amount,
  d.user_name
FROM orders o
LEFT JOIN dim_user_view FOR SYSTEM_TIME AS OF o.order_time d
ON o.user_id = d.user_id;

注意：如果视图基于普通Append模式的Kafka表创建，即使声明主键也无法作为版本化表参与Temporal Join，因为Append流无更新/删除事件，无法维护版本快照。

内容的提问来源于stack exchange，提问作者user3497321