FlinkSQL 1.12 Temporal Joins 多表关联问题

Thu, 11 Nov 2021 01:42:34 -0800 

Hi :
   现在有个场景， 我有一张Kafka的表，需要基于这张Kafka的流表 进行事件触发，去关联DB的多表 来拉宽数据 。比如： select * from 
kafkaTableA AS A
   join DBTableB FOR SYSTEM_TIME AS OF A.`PROCTIME` AS B ON valueB = B.columnB  
   join DBTableC FOR SYSTEM_TIME AS OF A.`PROCTIME` AS C  ON valueC = C.columnC 
。 
  目前有两个问题：
   1.  我看数据库里 是单表去查询数据的数据的， 
         select * from DBTableB where B.columnB   = valueB 
         select * from DBTableC where C.columnC   = valueC
      这里我可以配置 把整个查询逻辑 下沉到数据库去做吗？
  2. 我想把Kafka 里的数据 积累一点之后 通过微批的形式 IN 查询 请问 有没有可能这么做？



---
Best,
WuKong

回复