phoneix的安装部署以及使用

1.下载

在官网http://www.apache.org/dyn/closer.lua/phoenix/中选择提供的镜像站点中下载与安装的HBase版本对应的版本。本地使用的1.3.1，故下载的apache-phoenix-4.11.0-HBase-1.3/的tar.gz包。

 

2.3   安装配置

声明：本人由于之前脑壳子瓦特了，

          主机名：sparkKing-master   从节点：sparkKing-salve   sparkKing-salve02   

           用户名：matser

2.3.1   上传phoenix到master

       使用secureCRT或者其他传输工具将下载的tar包上传到hbase集群的master结点中。

       $cd /home/master/

       $tar -zxvf apache-phoenix-4.11.0-HBase-1.3-bin.tar.gz

2.3.2    拷贝phoenix-core-4.11.0-HBase-1.3.jar到RegionServer

       将phoenix-core-4.11.0-HBase-1.3.jar拷贝到hbase集群中的所有region server的hbase的lib目录下。在测试环境下，master和slave01均作为regionserver。

       $cd /home/master/apache-phoenix-4.11.0-HBase-1.3-bin

       $cp phoenix-core-4.11.0-HBase-1.3.jar /home/master/hbase/lib 拷贝到master

       $scp -r phoenix-core-4.11.0-HBase-1.3.jar [email protected]:/home/master/hbase/lib 拷贝到slave01

      $scp -r phoenix-core-4.11.0-HBase-1.3.jar [email protected]:/home/master/hbase/lib 拷贝到slave02

2.3.3   拷贝phoenix-4.14.0-HBase-1.3-server.jar到RegionServer

       将phoenix-4.14.0-HBase-1.3-server.jar拷贝到hbase集群中的所有region server的hbase的lib目录下。在测试环境下，master和slave01均作为regionserver。

       $cd /home/master/apache-phoenix-4.11.0-HBase-1.3-bin

       $cp phoenix-core-4.11.0-HBase-1.3.jar /home/master/hbase/lib 拷贝到master

       $scp -r phoenix-4.14.0-HBase-1.3-server.jar [email protected]:/home/master/hbase/lib 拷贝到slave01

      $scp -r phoenix-4.14.0-HBase-1.3-server.jar [email protected]:/home/master/hbase/lib 拷贝到slave02

2.3.4     重启hbase

       $cd /home/hadoop/hbase/bin

       $./stop-hbase.sh

       $./start-hbase.sh

3  phoenix命令行使用

3.1     进入命令行

       $cd /home/master/apache-phoenix-4.11.0-HBase-1.3-bin/bin进入phoenix的bin目录

       $./sqlline.py  master                    其中的master为Zookeeper所在节点的主机名

3.2     测试

• 首先，让我们创建一个包含表定义的us_population.sql文件：

• CREATE TABLE IF NOT EXISTS us_population (
        state CHAR(2) NOT NULL,
        city VARCHAR NOT NULL,
        population BIGINT
        CONSTRAINT my_pk PRIMARY KEY (state, city));

• 现在让我们创建一个us_population.csv文件，其中包含要放入该表的一些数据：

• NY,New York,8143197
  CA,Los Angeles,3844829
  IL,Chicago,2842518
  TX,Houston,2016582
  PA,Philadelphia,1463281
  AZ,Phoenix,1461575
  TX,San Antonio,1256509
  CA,San Diego,1255540
  TX,Dallas,1213825
  CA,San Jose,912332

• 最后，让我们创建一个包含我们想要在该数据上运行的查询的us_population_queries.sql文件。

• SELECT state as "State",count(city) as "City Count",sum(population) as "Population Sum"
  FROM us_population
  GROUP BY state
  ORDER BY sum(population) DESC;

• 从命令终端执行以下命令
• [[email protected] bin]$ ./psql.py sparkKing-master:2181 ~/us_population.sql ~/us_population.csv ~/us_population_queries.sql
• 截图如下
• 
•