有谁用Flink cdc做过打宽表呢？

在Apache Flink的CDC（Change Data Capture）场景中，使用FOR SYSTEM_TIME AS OF语法进行维表join时，这个语法确实主要是与表名直接关联的，而不是一个子查询（如SELECT * FROM 表名）。这是因为在Flink SQL中，FOR SYSTEM_TIME AS OF是用来实现时间点快照读取（time-windowed snapshot reads）的功能，它允许你查询某个表在某一时间点的快照状态，这对于处理时态数据和实现Exactly-Once语义特别有用。

具体到你的问题，如果你想基于动态查询结果进行join，直接将(SELECT * FROM 表名)放在AS OF之前是不被支持的。正确的做法是先定义一个临时表或者视图，然后在这个临时表或视图上应用FOR SYSTEM_TIME AS OF语法。下面是大致的步骤：

1. 创建或定义维表视图：如果你需要基于某些条件筛选维表数据，可以先创建一个视图（View）。

   CREATE VIEW filtered_dim_table AS SELECT * FROM dim_table WHERE some_condition;
   

2. 在主查询中使用视图进行时间一致的join：接下来，在你的主要查询中，你可以使用这个视图，并应用FOR SYSTEM_TIME AS OF来确保一致性。

   SELECT 
    main_table.*, 
    dim_data.dimension_column 
   FROM 
    main_table 
   JOIN 
    filtered_dim_table FOR SYSTEM_TIME AS OF main_table.join_time AS dim_data 
   ON 
    main_table.join_key = dim_data.join_key;
   

这里，main_table.join_time应该是一个包含你想要查询的时间戳的字段，而dim_table已经被替换为之前定义的视图filtered_dim_table。这样，即使维表数据有变化，也能保证按照指定时间点的数据进行join操作。

请注意，实际应用中可能需要根据你的具体需求调整SQL语句，包括表名、字段名以及条件等。