本地CSV檔案測試： 2. 建立表 在phoenix的CLI介面建立user表。 > create table CSV_BULK_LOAD (id varchar primary key,account varchar ,passwd varchar); 3. 新增測試資料 在【PHOENIX_HOME】目錄下建立data.csv，內容如下： 001,google,AM  002,baidu,BJ  003,alibaba,HZ 4.在phoenix目錄中執行： bin/psql.py -t CSV_BULK_LOAD test/data.csv SLF4J: Class path contains multiple SLF4J bindings. SLF4J: Found binding in [jar:file:/home/phoenix4.9.0/phoenix-4.9.0-HBase-1.2-client.jar!/org/slf4j/impl/StaticLoggerBinder.class] SLF4J: Found binding in [jar:file:/home/hadoop2.73/share/hadoop/common/lib/slf4j-log4j12-1.7.10.jar!/org/slf4j/impl/StaticLoggerBinder.class] SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 17/08/16 16:56:28 WARN util.NativeCodeLoader: Unable to load native-hadoop library for your platform... using builtin-java classes where applicable csv columns from database. CSV Upsert complete. 3 rows upserted Time: 0.086 sec(s) 5.檢視 0: jdbc:phoenix:> select * from CSV_BULK_LOAD +------+----------+---------+ | ID | ACCOUNT | PASSWD | +------+----------+---------+ | 001 | google | AM | | 002 | baidu | BJ | | 003 | alibaba | HZ | +------+----------+---------+ 3 rows selected (0.083 seconds) 6.利用MapReduce插入普通檔案 data2.txt 004,aaagoogle,EEEEAM 005,dddddbaidu,EEEEBJ 006,cccccalibaba,EEEEHZ 7.在phoenix目錄下 （data2.txt也需要在同一個目錄，不能有子目錄，不知道為啥） [[email protected] phoenix4.9.0]# HADOOP_CLASSPATH=/home/hbase1.25/lib/hbase-protocol-1.2.5.jar:/home/hbase1.25/conf hadoop jar phoenix-4.9.0-HBase-1.2-client.jar org.apache.phoenix.mapreduce.CsvBulkLoadTool -t CSV_BULK_LOAD -i file:/home/phoenix4.9.0/data2.txt -z 172.16.11.221,172.16.11.222,172.16.11.223:2800 -z 如果不專門指定 預設訪問的埠是2181 ，當然埠值看自己hadoop hbase裡是多少 MapReduce載入器可以使用以下引數。

引數	描述
-i，-input	輸入CSV路徑（必填）
-t， - table	鳳凰臺名（強制性）
-a， - array-delimiter	陣列元素分隔符（可選）
-c，-import-columns	要匯入的列的逗號分隔列表
-d，-delimiter	輸入分隔符，預設為逗號
-g，-ignore-errors	忽略輸入錯誤
-o，-output	臨時HFiles的輸出路徑（可選）
-s，-schema	鳳凰模式名稱（可選）
-z，-zookeeper	Zookeeper quorum連線（可選）
- it，-index-table	要載入的索引表名稱（可選）

8.檢視： 0: jdbc:phoenix:> select * from CSV_BULK_LOAD +------+---------------+----------+ | ID | ACCOUNT | PASSWD | +------+---------------+----------+ | 001 | google | AM | | 002 | baidu | BJ | | 003 | alibaba | HZ | | 004 | aaagoogle | EEEEAM | | 005 | dddddbaidu | EEEEBJ | | 006 | cccccalibaba | EEEEHZ | +------+---------------+----------+ 9 MapReduce importer 匯入Hfiles data3.csv 007,MMMMgoogle,HHHHHAM 008,AAAAbaidu,EEEEEBJ 009,CCCCalibaba,NNNNNHZ 10.利用 importer 匯入 [[email protected] phoenix4.9.0]# hadoop jar phoenix-4.9.0-HBase-1.2-client.jar org.apache.phoenix.mapreduce.CsvBulkLoadTool -t CSV_BULK_LOAD -i /Phoenix/data3.csv -z 172.16.11.221,172.16.11.222,172.16.11.223:2800 11.檢視： 0: jdbc:phoenix:> select * from CSV_BULK_LOAD; +------+---------------+-----------+ | ID | ACCOUNT | PASSWD | +------+---------------+-----------+ | 001 | google | AM | | 002 | baidu | BJ | | 003 | alibaba | HZ | | 004 | aaagoogle | EEEEAM | | 005 | dddddbaidu | EEEEBJ | | 006 | cccccalibaba | EEEEHZ | | 007 | MMMMgoogle | HHHHHAM | | 008 | AAAAbaidu | EEEEEBJ | | 009 | CCCCalibaba | NNNNNHZ | +------+---------------+-----------+