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