hadoop - PIG - HBASE - HBaseStorage 密钥过滤器 (gt, lt)

Question

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

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

这是我所在的位置：

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);