开发者社区> 问答> 正文

SQL层应用维表join jdbc的时候,请问怎么动态感知维表数据的变化呢?

hi~ 如图所示,在做kafka和jdbc join的时候,jdbc数据全量加载并为Finished状态,这种情况下请问怎么感知jdbc表的数据更新呢?还是我哪里的配置不对,还请赐教

小白敬上~*来自志愿者整理的flink邮件归档

展开
收起
船长的小螺号 2021-12-03 10:12:44 1178 0
1 条回答
写回答
取消 提交回答
  • 邮件列表里不支持直接发送图片,你可以用一些图床工具来发送图片。

    根据你的描述,我猜测你应该是join维表的语法写的不对,写成了普通的join的方式。这种情况下,会把jdbc的表解析成JDBCInputFormat,一次性读取全部数据。

    维表join的SQL写法如下所示:

    SELECT

    o.amout, o.currency, r.rate, o.amount * r.rateFROM

    Orders AS o* JOIN LatestRates FOR SYSTEM_TIME AS OF o.proctime AS r

    • ON r.currency = o.currency

    详细内容可以参考文档:

    https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/table/sql.html#joins*来自志愿者整理的FLINK邮件归档

    2021-12-03 10:45:39
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
SQL Server 2017 立即下载
GeoMesa on Spark SQL 立即下载
原生SQL on Hadoop引擎- Apache HAWQ 2.x最新技术解密malili 立即下载