我正在使用以下linux命令:
hadoop jar phoenix-4.6.0-HBase-0.98-client.jar org.apache.phoenix.mapreduce.CsvBulkLoadTool --table TT --input /tmp/text.csv
此命令工作成功,但hbase表中没有加载csv文件中的数据,但数据已成功加载到索引表(为tt的索引表导入csv文件)。
环境:
hbase 0.98.9版
hadoop 2.6.0版
Phoenix4.6-hbase-0.98
案例1:索引覆盖所有列
1)
CREATE TABLE example (
my_pk bigint not null,
m.first_name varchar(50),
m.last_name varchar(50)
CONSTRAINT pk PRIMARY KEY (my_pk))
CREATE INDEX index_example on example(m.last_name ASC) include (m.first_name)
or create index index_example on example(m.first_name,m.last_name)
hadoop jar phoenix-4.6.0-HBase-0.98-client.jar org.apache.phoenix.mapreduce.CsvBulkLoadTool --table example --input /tmp/text1.csv --index-table INDEX_EXAMPLE
select * from example
成功与有数据
select * from index_example
成功与有数据
测试用例:org.apache.phoenix.mapreduce.csvbulkloadtoolit.testimportwithindex()
案例2:列的索引覆盖部分
1)
CREATE TABLE example (
my_pk bigint not null,
m.first_name varchar(50),
m.last_name varchar(50)
CONSTRAINT pk PRIMARY KEY (my_pk))
create index index_example on example(m.last_name ASC)
hadoop jar phoenix-4.6.0-HBase-0.98-client.jar
org.apache.phoenix.mapreduce.CsvBulkLoadTool --table example --input /tmp/text1.csv --index-table INDEX_EXAMPLE
select * from example
成功但没有数据
select * from index_example
成功有数据吗
测试用例:org.apache.phoenix.mapreduce.csvbulkloadtoolit.testimportoneindextable()
1条答案
按热度按时间ftf50wuq1#
这是phoenix中的一个已知错误,当您的表名为小写时。你需要用双引号把它们括起来