发布者:全栈程序员栈长,转载请注明出处:https://javaforall.cn/151771.html原文链接:https://javaforall.cn
那么索引数据的导入还需要采用phoenix提供的索引同步工具类 IndexTool , 这是一个mapreduce工具类,使用方式如下: $HBASE_HOME/bin/hbase org.apache.phoenix.mapreduce.index.IndexTool
一 安装部署 1, 下载 http://archive.apache.org/dist/phoenix/ 本文下载的是apache-phoenix-4.12.0-HBase-1.2-bin.tar.gz...2, 安装 解压之后将phoenix-4.12.0-HBase-1.2-server.jar复制到hbase/lib目录下。...在phoenix的bin目录下执行: sqlline.py [zookeeper] ....映射hbase表到phoenix: 比如,在hbase上创建表t1,然后映射到phoenix上,分两步: 1, 创建hbase表 create 't1', {NAME => 'f1', VERSIONS...VARCHAR) Hbase表中插入一条数据,phoenix表中查询 put 't1','1001','f1:VAL','lisi' 同时创建hbase和phoenix表: 也可以直接使用cteate
PostgreSQL连接数据库的两种方式 PostgreSQL在安装时自带了pgAdmin和psql,pgAdmin是可视化工具,psql是命令行工具。...推荐使用psql来连接数据库进行备份和恢复db,同样大小的db,使用psql来restore会比pgAdmin快上数倍!...psql连接数据库 直接连接到指定的数据库 1 psql -h -p -d -U 如果host...先登陆psql控制台,再连接指定的数据库 psql命令也可以不指定某个数据库,如下: 1 psql -h -p -U 这时候登陆成功后会进入...退出psql控制台 和其他的命令行工具不一样,psql在退出时并不是使用exit,而是使用\q,接着按下回车就行了,这里的q指的就是quit。
注意: 对于全局索引在默认情况下,在查询语句中检索的列如果不在索引表中,Phoenix不会使用索引表将,除非使用hint。...~]# cd /opt/cloudera/parcels/ [root@node00 parcels]# cd APACHE_PHOENIX/lib/phoenix [...root@node00 phoenix]# cp phoenix-4.14.0-cdh5.12.2-client.jar /opt/cloudera/parcels/CDH/jars/.../jars/phoenix-4.14.0-cdh5.12.2-client.jar phoenix-4.14.0-cdh5.12.2-client.jar 索引用法总结 Phoenix 的二级索引主要有两种...索引定义完之后,一般来说,Phoenix自己会判定使用哪个索引更加有效。 但是,全局索引必须是查询语句中所有列都包含在全局索引中,它才会生效。
1.方案 这里我们通过Jpype和JayDeBeApi 来连接 2.过程 这里我列出实例代码: import jpype import jaydebeapi import os phoenix_client_jar...="/data/users/huser/phoenix/phoenix-4.3.0-client.jar" args=='-Djava.class.path=%s'% phoenix_client_jar...jvm_path=jpype.getDefaultJVMPath() jpype.startJVM(jvm_path,args) conn=jaydebeapi.connect('org.apache.phoenix.jdbc.PhoenixDriver...',['jdbc:phoenix:bj-g2hdp1,bj-g2hdp2,bj-g2hdp3:2181','',''],phoenix_clinent_jar) curs=conn.cursor() sql
1.phoenix 利用CsvBulkLoadTool 批量带入数据并自动创建索引 在phoenix 目录下执行 hadoop jar /home/phoenix-4.6.0-HBase-1.0-bin.../phoenix-4.6.0-HBase-1.0-client.jar org.apache.phoenix.mapreduce.CsvBulkLoadTool -t POPULATION -i /...2.phoenix 自带sql导入工具 ..../psql.py centos1,centos2,centos3 /home/ico11.sql 3.java代码批量插入 public class PhoenixSQL { public static...中,关系型数据库的数值类型到hbase中变成字节类型,映射到phoenix中,数值类型数据值改变了
Phoenix是什么 简单来说,Phoenix 是一个可以让我们通过SQL的方式操作HBase数据库的框架。...Phoenix 支持通过编写JDBC代码来操作HBase,比原生API更方便。.../psql.py localhost us_population.csv 查询表数据: 0: jdbc:phoenix:localhost> select * from US_POPULATION;...示例 Phoenix自带了一个web统计的小示例,先执行命令把他导入进来: bin/psql.py localhost examples/WEB_STAT.sql examples/WEB_STAT.csv...小结 Phoenix 的基础功能就是在 HBase 之上添加了 SQL 层,可以让我们更方便的使用 HBase。
Phoenix 相对于 HBase 来说就是一个支持 SQL 的客户端软件,为能在集群环境中任何节点上都能使用 Phoenix 命令行,在所有节点上都安装。...添加下面两行 export PHOENIX_HOME=/root/phoenix-hbase-2.5-5.1.3-bin/ export PHOENIX_CLASSPATH=$PHOENIX_HOME...将 phoenix-server-hbase-2.5-5.1.3.jar 文件复制到 HBase 的 lib 目录中 cp $PHOENIX_HOME/phoenix-server-hbase-2.5-...如果要在 Phoenix 中操作直接在 HBase 中创建的表,则需要在 Phoenix 中进行表的映射。映射方式有两种:视图映射和表映射。...参考: Apache Phoenix 映射已存在 HBase 表,查询不到数据 https://phoenix.apache.org/installation.html
一、简介 1、Phoenix定义 1)官网地址:http://phoenix.apache.org/ Phoenix是HBase的开源SQL皮肤。...2、Phoenix架构 二、安装Phoenix 1、安装 将安装包上传到服务器目录 解压安装包 tar -zxvf apache-phoenix-5.0.0-HBase-2.0-bin.tar.gz -.../my_env.sh 添加内容 #phoenix export PHOENIX_HOME=/opt/module/phoenix export PHOENIX_CLASSPATH=$PHOENIX_HOME.../opt/module/phoenix/bin/sqlline.py hadoop101,hadoop102,hadoop103:2181 三、Phoenix操作 1、Phoenix 数据映射 Phoenix...2、Phoenix Shell操作 登录Phoenix /opt/module/phoenix/bin/sqlline.py hadoop101,hadoop102,hadoop103:2181 创建表
phoenix可以处理实时数据 (1)启动数据库的连接 bin/sqlline.py数据库安装服务器ip或主机名:zookeeper的服务端口号 !table查看所有的表使用 !...)创建表 create table hbase_test ( s1 varchar not null primary key, s2 varchar, s3 varchar, s4 varchar 在phoenix...是查看不到的 如果需要在phoenix中操作直接在hbase中创建的表,则需要在phoenix中进行表的映射。...表映射的话,在phoenix中的表与hbase中的表会被同时删除与修改,视图映射中的表删除,hbase中的表不会被删除。...address"varchar); 种情况下,直接使用与第1)种情况一样的createtable语句进行创建即可,这样系统将会自动在Phoenix和HBase中创建person_infomation的表
3.Apache Phoenix是什么 ---- 首先Phoenix是HBase之上的SQL工具,至于HBase是什么,我就不介绍了,你若不懂,就不需要往下继续看了。...7.Phoenix的命令行工具 ---- Phoenix的命令行工具在/usr/bin目录下,在使用Phoenix的命令行工具之前,需要配置Java的环境变量。...比如:sqlline.py zk01.example.com:2181 sql_queries.sql phoenix-psql.py可以用来加载CSV数据,后面也可以直接带上需要执行的SQL脚本,也可以不加...比如:phoenix-psql.py zk01.example.com:2181 create_stmts.sql data.csvsql_queries.sql 性能测试脚本phoenix-performance.py...比如:phoenix-psql.py zk01.example.com:2181 100000 8.接下来的工作 ---- Phoenix项目正在调研使用Tephra(来自CASK)来做事务管理,PHOENIX
查找有关 Apache Phoenix 及其部署的常见问题解答。 Phoenix 可以用于 ETL 用例吗? 是的。...Phoenix 在全局索引维护期间执行本地索引以防止死锁。:当索引更新失败时,Phoenix 还会部分自动重建索引 ( PHOENIX-1112 )。 序列如何在Phoenix工作?...CSV 可以使用名为 psql 的内置实用程序批量加载 CSV 数据。典型的 upsert 速率是每秒 20K - 50K 行(取决于行的宽度)。...用法示例: 使用 psql 创建表$ psql.py [zookeeper] ...../examples/web_stat.sql Upsert CSV 批量数据$ psql.py [zookeeper] ..
查找有关Apache Phoenix及其部署的常见问题的答案。 01 Phoenix可以用于ETL用例吗? 是。...典型的Phoenix部署具有以下特点: • 应用 • Phoenix Client / JDBC驱动程序 • HBase客户端 Phoenix客户端/ JDBC驱动程序本质上是一个Java库,您应该在...但是,Phoenix的抽象尚未完成,例如,为了实现访问控制,您需要在包含Phoenix数据的基础HBase表上设置ACL。 ? 03 是否有Phoenix JDBC服务器的大小调整准则?...Phoenix在全局索引维护期间执行本地索引以防止死锁:Phoenix还会在索引更新失败时部分地自动重建索引(PHOENIX-1112 )。 07 序列在Phoenix中如何工作?...数据是由Phoenix编码的,因此您必须对数据进行解码才能读取。直接写入HBase表会导致Phoenix损坏。 11 我可以在现有的HBase表上映射Phoenix表吗?
Phoenix 大数据的同学肯定对其很了解,是Apache基金会下的顶级工程,Phoenix帮助Hbase提供了SQL语法的支持,让难用的Hbase变得简单易用。...现状 使用HBase作为数据的持久化 场景对接口的TPS要求比较高 操作方式简单 问题与方案 Hbase是一种很好的大数据存储方案,但是其不支持SQL化操作,在开源解决方案中提供了Phoenix方案,文档和社区都比较活跃...实现 只对涉及Phoenix方面进行讲解,通过Scala进行编写 依赖Pom io.vertx vertx-jdbc-client org.apache.phoenix... phoenix-core 4.13.1-HBase-1.3 </dependency
下载安装 首先从 apache 下载 phoenix 包,这里因为我的hbase hbase-1.4.9 版,所以我下载的对应的版本 apache-phoenix-4.14.1-HBase-1.4-bin.tar.gz...下载后解压之 apache-phoenix-4.14.1-HBase-1.4-bin.tar.gz tar zxvf apache-phoenix-4.14.1-HBase-1.4-bin.tar.gz...准备 hbase 为了使用 phoenix,需要将 phoenix 目录下的 phoenix-*。...jar 包复制到 hbase 的 lib 目录下,比如: cp apache-phoenix-4.14.1-HBase-1.4-bin/phoenix-*.jar hbase-1.4.9/lib/ 然后重新系统.../start-hbase.sh 连接phoenix 可以使用下面两种方式连接 方式一:直接连接 cd apache-phoenix-4.14.1-HBase-1.4-bin/bin # 默认连接本地hbase
操作过程: 第一步删除phoenix中系统的表格信息,主要为SYSTEM.CATALOG,第二步删除Hbase中的表格信息。...操作步骤: (1)查询phoenix系统表 SYSTEM.CATALOG 内容是所有表格的信息,系统表和自建表 SYSTEM.FUNCTION 内容是所有函数信息,系统函数和自定义函数 SYSTEM.SEQUENCE
phoenix自带了执行sql脚本的功能,这样方便了希望能够直接将一些关系型数据库的数据进行迁移到Hbase(也可以直接使用sqoop进行导入)。...在【PHOENIX_HOME】目录下创建user.sql,内容如下: -- create table user create table if not exists user (id varchar primary...upsert into user(id, account, passwd) values('003', 'zx', 'zx'); -- query data select * from user;在【PHOENIX_HOME.../bin/psql.py 192.168.187.128,192.168.187.129,192.168.187.130:2181 user.sql
目录 一、下载并安装Phoenix parcel 二、安装CSD文件 三、在Cloudera Manager中添加Phoenix服务(前提是已经安装了HBase服务) 四、配置HBase以用于Phoenix...五、验证Phoenix安装 参考: ---- 一、下载并安装Phoenix parcel 1....图7 四、配置HBase以用于Phoenix 1....重启Hbase服务 五、验证Phoenix安装 登录集群主机,并在命令提示符下运行以下冒烟测试: phoenix-psql /opt/cloudera/parcels/PHOENIX-5.0.0-cdh6.2.0.../lib/phoenix/examples/WEB_STAT.csv /opt/cloudera/parcels/PHOENIX-5.0.0-cdh6.2.0.p0.1308267/lib/phoenix
官网地址 phoenix https://phoenix.apache.org/language/ 下载地址:http://archive.apache.org/dist/phoenix/...(2)拷贝phoenix-4.3.1-server.jar到Hbase的lib目录下 (3)重启hbase (4)进入phoeinx的bin目录下 (5)执行bin/sqlline.py...tables查看所有的表 文档地址: phoenix https://phoenix.apache.org/language/ SQuirrel是一个用Java写的通过jdbc驱动链接各个数据库的图形界面...安装完成后,把phoeinx的client和core的jar包,放入squirrel的安装目录的lib下面,然后双击squirrel-sql.bat启动 test-phoenix jdbc:phoenix...:192.168.1.212 org.apache.phoenix.jdbc.PhoenixDriver (1)先建立驱动,通过链接 ?
领取专属 10元无门槛券
手把手带您无忧上云