猪- HBASE - HBaseStorage密钥过滤器(gt，lt)

Question

在猪脚本中，我使用HBaseStorage从HBase表加载所有行。但是，我想按行键过滤行。

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

我现在在这里：

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

如果可能的话，请提供示例代码..。

Answer 1

您可以在十六进制数字中使用"\x“来表示二进制值。检查源代码这里。例如,

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