我在看这两篇文档，目前hbase 和jdbc定义的数据源是可以关联的，你可以看一下。 https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/table/streaming/joins.html#event-time-temporal-joins https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/table/connect.html
在 2019-12-05 14:24:56，"猫猫" <[email protected]> 写道： >注册两个数据源，然后直接在sql中join就可以了。 > > >这里的意思是，将源转化为flink table，多个table是可以相互join的。 > > >我也想知道：目前flin支持哪些类型的注册源，以及相关的语法怎么能够找到。 > > >------------------ 原始邮件 ------------------ >发件人: "陈赋赟"<[email protected]>; >发送时间: 2019年12月5日(星期四) 下午2:22 >收件人: "user-zh"<[email protected]>; > >主题: Re:回复：想问一下Flink SQL 1.9版本支持维表join吗 > > > > >我想知道可以用sql 直接关联外部数据源吗？ 这个好像是读kafka数据写入mysql，当中并没有关联外部数据源的操作。 > > > > > > > >在 2019-12-05 14:17:28，"猫猫" <[email protected]> 写道： >>正好在看这篇文档，但是我想做一个csv的数据源，不知道格式怎么配置。 >>https://yq.aliyun.com/articles/717034 >> >> >>------------------&nbsp;原始邮件&nbsp;------------------ >>发件人:&nbsp;"陈赋赟"<[email protected]&gt;; >>发送时间:&nbsp;2019年12月5日(星期四) 下午2:15 >>收件人:&nbsp;"user-zh"<[email protected]&gt;; >> >>主题:&nbsp;想问一下Flink SQL 1.9版本支持维表join吗 >> >> >> >>想问一下，目前flink sql 1.9 可以通过sql的方式 join 关联外部数据源吗？ >>比如说通过sql DDL 定义一个Hbase的维表数据源,然后用sql join关联上。 >> >> >>CREATETABLEMyUserTable( >>hbase_rowkey_namerowkey_type, >>hbase_column_family_name1ROW<...&gt;, >>hbase_column_family_name2ROW<...&gt; >>)WITH( >>'connector.type'='hbase',... >>) >> >> >>SELECT >>tb1.xx >>MyUserTable.xx >>FROM >>tb1 >>JOIN >>MyUserTable ON >>tb1.xx = MyUserTable.xx
