想问一下,目前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*来自志愿者整理的flink邮件归档
正好在看这篇文档,但是我想做一个csv的数据源,不知道格式怎么配置。
https://yq.aliyun.com/articles/717034
*来自志愿者整理的flink邮件归档
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。