Re: Re: FlinkSQL 1.12 Temporal Joins ????????????

[????]

Hi :
   ?????? ????????Cache 
???????????????????????????????????????????????? ?????????????????? 
???????????????????? ??????Job ?? ??????????????????In ???? ????????
   ??????  ??????????????????????????????Flink Sql ?????????? 
????????????????????????????OLAP ???? ????????????????????
 


 ---
Best,
WuKong

  
???????? Caizhi Weng
?????????? 2021-11-12 11:32
???????? flink??????????
?????? Re: FlinkSQL 1.12 Temporal Joins ????????????


Hi??
  
 
????????????????????????????????????????????????????????????????????????????????????????????????
  
 ?????????????????????????? jdbc ?? hbase?????? cache ???? [1]??cache 
?????????????? cache ??????????????????????
 task manager ???????????????????????????????? task manager 
????????????????????????????????????????????
  
 ??????????????????????????????????????????????????????????
  
 [1]
 
https://nightlies.apache.org/flink/flink-docs-master/zh/docs/connectors/table/jdbc/#lookup-cache
  
 WuKong <wukon...@foxmail.com&gt; ??2021??11??11?????? ????5:42??????
 &nbsp;
 &gt; Hi :
 &gt;&nbsp; &nbsp; ?????????????? ????????Kafka??????????????????Kafka?????? 
????????????????????DB?????? ?????????? ???????? select *
 &gt; from kafkaTableA AS A
 &gt;&nbsp; &nbsp; join DBTableB FOR SYSTEM_TIME AS OF A.`PROCTIME` AS B ON 
valueB =
 &gt; B.columnB
 &gt;&nbsp; &nbsp; join DBTableC FOR SYSTEM_TIME AS OF A.`PROCTIME` AS C&nbsp; 
ON valueC =
 &gt; C.columnC ??
 &gt; &nbsp; ????????????????
 &gt;&nbsp; &nbsp; 1.&nbsp; ???????????? ??????????????????????????
 &gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp; select * from DBTableB 
where B.columnB &nbsp; = valueB
 &gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp; select * from DBTableC 
where C.columnC &nbsp; = valueC
 &gt;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp; ?????????????? ?????????????? 
????????????????????
 &gt; &nbsp; 2. ??????Kafka ???????? ???????????? ?????????????? IN ???? ???? 
??????????????????
 &gt;
 &gt;
 &gt;
 &gt; ---
 &gt; Best,
 &gt; WuKong
 &gt;