我正在使用spark将oracle表导入hbase。我使用批量导入选项在hdfs暂存目录中生成hfiles。一旦我运行loadincrementalhfiles将数据加载到hbase表中。
hBaseContext.bulkLoad(rdds, TableName.valueOf("pink"), new BulkLoadFunction1(), "/solidk", new HashMap<byte[], FamilyHFileWriteOptions>(), false, HConstants.DEFAULT_MAX_FILE_SIZE);
hbase org.apache.hadoop.hbase.mapreduce.loadincrementalhfiles-dcreate.table=yes/solidk粉红色
其中/solidk是我的暂存目录,pink是表名。我可以看到正在创建表,并将hfiles移到hbase目录中,但scan返回0行。有人知道吗?
暂无答案!
目前还没有任何答案,快来回答吧!