代码拉取完成,页面将自动刷新
flink-connector-jdbc 增加了phoenix 的支持
CREATE TABLE base_dic (
dic_code STRING,
dic_name STRING,
PRIMARY KEY (dic_code) NOT ENFORCED
) WITH (
'connector' = 'jdbc' ,
'url' = 'jdbc:phoenix:hadoop102:2181',
'table-name' = 'GMALL2022.DIM_BASE_DIC'
) ;
如果有SCHEMA要放在表名前缀,库名表名都要大写。
想要查看修改的地方 可以搜索 FIXED FOR PHOENIX
<dependency>
<groupId>org.apache.phoenix</groupId>
<artifactId>phoenix-spark</artifactId>
<version>5.0.0-HBase-2.0</version>
<exclusions>
<exclusion>
<groupId>org.glassfish</groupId>
<artifactId>javax.el</artifactId>
</exclusion>
</exclusions>
</dependency>
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。