1 Star 1 Fork 6

windyzj / flink-connector-jdbc_extra_2.12

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
该仓库未声明开源许可证文件(LICENSE),使用请关注具体项目描述及其代码上游依赖。
克隆/下载
贡献代码
同步代码
取消
提示: 由于 Git 不支持空文件夾,创建文件夹后会生成空的 .keep 文件
Loading...
README

flink-connector-jdbc_extra_2.12

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

使用是要引入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>

空文件

简介

flink 的phoenix 连接器 展开 收起
Java
取消

发行版

暂无发行版

贡献者

全部

近期动态

加载更多
不能加载更多了
Java
1
https://gitee.com/windyzj/flink-connector-jdbc_extra_2.12.git
git@gitee.com:windyzj/flink-connector-jdbc_extra_2.12.git
windyzj
flink-connector-jdbc_extra_2.12
flink-connector-jdbc_extra_2.12
master

搜索帮助