Hello ... I have a question for you I am doing a pig job as following that read from hdfs simply to store hbase when i start the job first part works fine and second part was failure. Could you give me a direction how to move data from hdfs to Hbase
A = load '/passwd' using PigStorage(':');B = foreach A generate $0 as id, $2 as value;dump B; store B into 'table2' using org.apache.pig.backend.hadoop.hbase.HBaseStorage( 'cf:a' , '-loadKey');
thank you for your help Byambajargal On 4/25/11 18:26, Dmitriy Ryaboy wrote:
The first element of the relation you store must be the row key. You aren't loading the row key, so load> store isn't working. Try my_data = LOAD 'hbase://table1' using org.apache.pig.backend.hadoop.hbase.HBaseStorage('cf:1', '-loadKey') ; On Mon, Apr 25, 2011 at 5:32 AM, byambajargal<byambaa.0...@gmail.com>wrote:Hello guys I am running cloudere distribution cdh3u0 on my cluster with Pig and Hbase. i can read data from hbase using the following pig query: my_data = LOAD 'hbase://table1' using org.apache.pig.backend.hadoop.hbase.HBaseStorage('cf:1') ;dump my_data but when i try to store data into hbase as same way the job was failure. store my_data into 'hbase://table2' using org.apache.pig.backend.hadoop.hbase.HBaseStorage('cf:1'); the table1 and the table2 has same structure and same column. the table i have: hbase(main):029:0* scan 'table1' ROW COLUMN+CELL row1 column=cf:1, timestamp=1303731834050, value=value1 row2 column=cf:1, timestamp=1303731849901, value=value2 row3 column=cf:1, timestamp=1303731858637, value=value3 3 row(s) in 0.0470 seconds thanks Byambajargal
