执行Java中嵌入的HBASE和Pig时出错

Question

我在Pig中执行了这句话，它起作用了：

source =使用org.apache.pig.backend.hadoop.hbase.HBaseStorage( 'datos:bikes'，'-loadKey true')加载‘hbase://datos’) as (id1:int，bikes:int)；

我尝试在java的embeded Pig中执行相同的句子。代码是：

runMyQuery(pigServer，"hbase://DatosBicing")；

pigServer.registerQuery("source = load '"+ inputFile + "‘USING org.apache.pig.backend.hadoop.hbase.HBaseStorage(“+ "'datos:bikes')"+ "as (id1:chararray，bikes:chararray) ;")；

当我执行这段代码时，我得到了以下错误：

org.apache.pig.impl.logicalLayer.FrontendException:错误1000:解析过程中出错。Pig脚本无法分析: pig脚本无法验证: java.lang.RuntimeException:无法使用参数'datos:bikes‘实例化自行车

Java代码中的其他参数包括：

PigServer pigServer =新本地(“PigServer”)；

   pigServer.registerJar("/usr/lib/hbase/lib/zookeeper.jar");
   pigServer.registerJar("/usr/lib/hbase/lib/protobuf-java-2.4.0a.jar");

有人能帮帮我吗？

Answer 1

我认为您可以尝试下面的代码并显示结果。

pigServer.registerQuery("source =加载'"+ inputFile + "‘使用org.apache.pig.backend.hadoop.hbase.HBaseStorage(“+ "'datos:bikes'，'-loadKey true')"+ "as (id1:chararray，bikes:chararray) ;");