我编写了一个pig脚本,它从一个表中提取一个日期列,然后写入hbase中的另一个表:
register '/usr/hdp/current/phoenix-client/lib/phoenix-pig-4.2.0.2.2.9.0-3393.jar';
register '/usr/hdp/current/phoenix-client/phoenix-client.jar';
ALL_RECORDS = LOAD 'hbase://table/table_name_1/key_column,column_from'
USING org.apache.phoenix.pig.PhoenixHBaseLoader('localhost');
ALL_RECORDS_COPY_COL = FOREACH ALL_RECORDS GENERATE key_column, column_from as column_to;
--DUMP ALL_RECORDS_COPY_COL;
STORE ALL_RECORDS_COPY_COL INTO 'hbase://table_name_2/key_column,column_to' using org.apache.phoenix.pig.PhoenixHBaseStorage('localhost','-batchSize 5000');
文i取消注解转储所有记录和评论存储,它工作正常,并转储在屏幕上的数据。但如果我尝试使用store来存储hbase数据,它会说无法从表\ name \ u1/键\列、列\中读取数据,并且不会写入任何内容。我犯了什么错误吗?
暂无答案!
目前还没有任何答案,快来回答吧!