使用pig在hbase中的批量加载

Question

我在HDFS中有一个日志文件需要解析并放入Hbase表中。

我想用PIG来做这个。

我该如何去解决它。脚本脚本应该解析日志，然后放入Hbase？

Answer 1

猪脚本会（假设标签是在日志文件中的数据分隔符）：

A= load '/home/log.txt' using PigStorage('\t') as (one:chararray,two:chararray,three:chararray,four:chararray); 

STORE A INTO 'hbase://table1' USING org.apache.pig.backend.hadoop.hbase.HBaseStorage('P:one,P:two,S:three,S:four');