通过pig在hbase中增加列值命令

pbwdgjma  于 2021-06-25  发布在  Pig
关注(0)|答案(1)|浏览(338)

有没有办法用pig在hbase表中增加列值?
我正在尝试在pig中编写一些东西,它将使hbase表中的一列的值递增,该列的值等效于这个hbase shell命令:

hbase> incr ‘t1′, ‘r1′, ‘c1′

有可能用Pig做这个吗?

knpiaxh1

knpiaxh11#

您可以为此创建宏:

DEFINE incr(A, fld, num) RETURNS B {
    $B = foreach A generate k, ($fld + (long)$num) as (v:long);
}

A = load 'hbase://t1' using org.apache.pig.backend.hadoop.hbase.HBaseStorage(
 'f1:c1', '-caster=HBaseBinaryConverter -loadKey=true') as (k:chararray, v:long);

B = incr(A,v,3); --increment f1:c1 by 3

store B into 'hbase://t1' using org.apache.pig.backend.hadoop.hbase.HBaseStorage(
 'f1:c1', '-caster=HBaseBinaryConverter -loadKey=true');

相关问题