flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 陈赋赟 <astion_...@163.com>
Subject Re:回复:想问一下Flink SQL 1.9版本支持维表join吗
Date Thu, 05 Dec 2019 06:44:45 GMT
我在看这两篇文档,目前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,"猫猫" <16770864@qq.com> 写道:
>注册两个数据源,然后直接在sql中join就可以了。
>
>
>这里的意思是,将源转化为flink table,多个table是可以相互join的。
>
>
>我也想知道:目前flin支持哪些类型的注册源,以及相关的语法怎么能够找到。
>
>
>------------------&nbsp;原始邮件&nbsp;------------------
>发件人:&nbsp;"陈赋赟"<astion_leo@163.com&gt;;
>发送时间:&nbsp;2019年12月5日(星期四) 下午2:22
>收件人:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;
>
>主题:&nbsp;Re:回复:想问一下Flink SQL 1.9版本支持维表join吗
>
>
>
>
>我想知道可以用sql 直接关联外部数据源吗? 这个好像是读kafka数据写入mysql,当中并没有关联外部数据源的操作。
>
>
>
>
>
>
>
>在 2019-12-05 14:17:28,"猫猫" <16770864@qq.com&gt; 写道:
>&gt;正好在看这篇文档,但是我想做一个csv的数据源,不知道格式怎么配置。
>&gt;https://yq.aliyun.com/articles/717034
>&gt;
>&gt;
>&gt;------------------&amp;nbsp;原始邮件&amp;nbsp;------------------
>&gt;发件人:&amp;nbsp;"陈赋赟"<astion_leo@163.com&amp;gt;;
>&gt;发送时间:&amp;nbsp;2019年12月5日(星期四) 下午2:15
>&gt;收件人:&amp;nbsp;"user-zh"<user-zh@flink.apache.org&amp;gt;;
>&gt;
>&gt;主题:&amp;nbsp;想问一下Flink SQL 1.9版本支持维表join吗
>&gt;
>&gt;
>&gt;
>&gt;想问一下,目前flink sql 1.9 可以通过sql的方式 join 关联外部数据源吗?
>&gt;比如说通过sql DDL 定义一个Hbase的维表数据源,然后用sql join关联上。
>&gt;
>&gt;
>&gt;CREATETABLEMyUserTable(
>&gt;hbase_rowkey_namerowkey_type,
>&gt;hbase_column_family_name1ROW<...&amp;gt;,
>&gt;hbase_column_family_name2ROW<...&amp;gt;
>&gt;)WITH(
>&gt;'connector.type'='hbase',...
>&gt;)
>&gt;
>&gt;
>&gt;SELECT
>&gt;tb1.xx
>&gt;MyUserTable.xx
>&gt;FROM
>&gt;tb1
>&gt;JOIN
>&gt;MyUserTable ON
>&gt;tb1.xx = MyUserTable.xx
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message