栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

Clickhouse通过jdbc连接phoenix获取hbase数据(clickhouse-jdbc-bridge组件基于配置)

Clickhouse通过jdbc连接phoenix获取hbase数据(clickhouse-jdbc-bridge组件基于配置)

Clickhouse通过jdbc连接phoenix获取hbase数据(clickhouse-jdbc-bridge组件基于配置)

部署请参考
Clickhouse通过jdbc连接获取Mysql/Oracle数据(clickhouse-jdbc-bridge组件基于配置)
这里只是换一下json

ckjdbc.json 如下

 /server/hbase/drivers/phoenix-server-hbase-2.1-5.1.2.jar 所需要对应phoenix的依赖位置
{
  "$schema": "../datasource.jschema",
  "ckjdbc": {
    "aliases": [
      "self"
    ],
    "driverUrls": [
      "/server/hbase/drivers/phoenix-server-hbase-2.1-5.1.2.jar"
    ],
    "driverClassName": "org.apache.phoenix.jdbc.PhoenixDriver",
    "jdbcUrl": "jdbc:phoenix:101.34.236.169:2181:/hbase",
    "username": "",
    "password": "",
    "maximumPoolSize": 5
  }
}


下列名字尽量一致

运行clickhouse-jdbc-bridge
java -jar clickhouse-jdbc-bridge-2.0.0.jar
#如果成功运行,会出现已加载的数据源信息,
使用clickhouse-jdbc-bridge迁移数据 先用DBeaver或clickhouse-client创建表
#这个是创建一个连接 数据还是实时查的hbase
CREATE TABLE default.test2
(
    `ID` Int32,
    `NAME` String
)
ENGINE = JDBC('ckjdbc', 'WYS', 'TEST')

#这是建立一个同步库
CREATE TABLE test3(id Int32, NAME String) ENGINE = MergeTree
ORDER BY id
SETTINGS index_granularity = 8192;

#把对应库的数据插入到上面建立的对应库

INSERT INTO test3 SELECt * FROM jdbc('ckjdbc', 'SELECt * FROM WYS.TEST');
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/629619.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号