You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 猫猫 <16...@qq.com> on 2019/12/05 06:17:28 UTC
回复：想问一下Flink SQL 1.9版本支持维表join吗
正好在看这篇文档，但是我想做一个csv的数据源，不知道格式怎么配置。
https://yq.aliyun.com/articles/717034
------------------ 原始邮件 ------------------
发件人: "陈赋赟"<astion_leo@163.com>;
发送时间: 2019年12月5日(星期四) 下午2:15
收件人: "user-zh"<user-zh@flink.apache.org>;
主题: 想问一下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
Re:回复：想问一下Flink SQL 1.9版本支持维表join吗
Posted by 陈赋赟 <as...@163.com>.
我在看这两篇文档，目前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，"猫猫" <16...@qq.com> 写道：
>注册两个数据源，然后直接在sql中join就可以了。
>
>
>这里的意思是，将源转化为flink table，多个table是可以相互join的。
>
>
>我也想知道：目前flin支持哪些类型的注册源，以及相关的语法怎么能够找到。
>
>
>------------------ 原始邮件 ------------------
>发件人: "陈赋赟"<astion_leo@163.com>;
>发送时间: 2019年12月5日(星期四) 下午2:22
>收件人: "user-zh"<user-zh@flink.apache.org>;
>
>主题: Re:回复：想问一下Flink SQL 1.9版本支持维表join吗
>
>
>
>
>我想知道可以用sql 直接关联外部数据源吗？ 这个好像是读kafka数据写入mysql，当中并没有关联外部数据源的操作。
>
>
>
>
>
>
>
>在 2019-12-05 14:17:28，"猫猫" <16770864@qq.com> 写道：
>>正好在看这篇文档，但是我想做一个csv的数据源，不知道格式怎么配置。
>>https://yq.aliyun.com/articles/717034
>>
>>
>>------------------&nbsp;原始邮件&nbsp;------------------
>>发件人:&nbsp;"陈赋赟"<astion_leo@163.com&gt;;
>>发送时间:&nbsp;2019年12月5日(星期四) 下午2:15
>>收件人:&nbsp;"user-zh"<user-zh@flink.apache.org&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
回复：想问一下Flink SQL 1.9版本支持维表join吗
Posted by 猫猫 <16...@qq.com>.
注册两个数据源，然后直接在sql中join就可以了。
这里的意思是，将源转化为flink table，多个table是可以相互join的。
我也想知道：目前flin支持哪些类型的注册源，以及相关的语法怎么能够找到。
------------------ 原始邮件 ------------------
发件人: "陈赋赟"<astion_leo@163.com>;
发送时间: 2019年12月5日(星期四) 下午2:22
收件人: "user-zh"<user-zh@flink.apache.org>;
主题: Re:回复：想问一下Flink SQL 1.9版本支持维表join吗
我想知道可以用sql 直接关联外部数据源吗？ 这个好像是读kafka数据写入mysql，当中并没有关联外部数据源的操作。
在 2019-12-05 14:17:28，"猫猫" <16770864@qq.com> 写道：
>正好在看这篇文档，但是我想做一个csv的数据源，不知道格式怎么配置。
>https://yq.aliyun.com/articles/717034
>
>
>------------------&nbsp;原始邮件&nbsp;------------------
>发件人:&nbsp;"陈赋赟"<astion_leo@163.com&gt;;
>发送时间:&nbsp;2019年12月5日(星期四) 下午2:15
>收件人:&nbsp;"user-zh"<user-zh@flink.apache.org&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
Re:回复：想问一下Flink SQL 1.9版本支持维表join吗
Posted by 陈赋赟 <as...@163.com>.
我想知道可以用sql 直接关联外部数据源吗？ 这个好像是读kafka数据写入mysql，当中并没有关联外部数据源的操作。
在 2019-12-05 14:17:28，"猫猫" <16...@qq.com> 写道：
>正好在看这篇文档，但是我想做一个csv的数据源，不知道格式怎么配置。
>https://yq.aliyun.com/articles/717034
>
>
>------------------ 原始邮件 ------------------
>发件人: "陈赋赟"<astion_leo@163.com>;
>发送时间: 2019年12月5日(星期四) 下午2:15
>收件人: "user-zh"<user-zh@flink.apache.org>;
>
>主题: 想问一下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