使用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');