在PIG脚本中,我使用HBaseStorage从HBase表中加载所有行。但是,我想通过rowkey来过滤行。

我查看了源代码,并且可以通过构造函数发送-gt&-lt。但是,我不知道如何将我的值传递给构造函数。这是一个字节[] ...

这是我的位置:

LOAD 'hbase://TABLE' USING org.apache.pig.backend.hadoop.hbase.HBaseStorage('CF:I','-caster HBaseBinaryConverter') AS (product_id:bytearray);

如果可能,请提供示例代码...

最佳答案

您可以将“\ x”与十六进制数字一起使用以表示二进制值。检查源代码here。例如,

LOAD 'hbase://TABLE' USING org.apache.pig.backend.hadoop.hbase.HBaseStorage('CF:I','-caster HBaseBinaryConverter -lt=\\x01\\x02\\xD4') AS (product_id:bytearray);

关于hadoop - PIG-HBASE-HBaseStorage键过滤器(gt,lt),我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/18730784/

10-16 06:09