我在Pig身上执行了这句话,它起了作用:
源=加载'hbase://datosbicing'使用org.apache.pig.backend.hadoop.hbase.hbastorage('datos:bikes“,”-loadkey true“)作为(id1:int,bikes:int);
我试着在java的嵌入式pig中执行相同的句子。代码是:
runmyquery(pigserverhbase://datosbicing");
使用org.apache.pig.backend.hadoop.hbase.hbasestorage(“+”)的pigserver.registerquery(“source=load'”+inputfile+“”datos:bikes')“+”as(id1:字符,bikes:chararray) ;");
当我执行这个代码时,我有一个错误:
org.apache.pig.impl.logicalayer.frontendexception:错误1000:解析期间出错。pig脚本未能分析:pig脚本未能验证:java.lang.runtimeexception:无法用参数示例化“org.apache.pig.backend.hadoop.hbase.hbasestorage”[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");
有人能帮我吗?
1条答案
按热度按时间y1aodyip1#
我想你可以尝试下面的代码并显示结果。
使用org.apache.pig.backend.hadoop.hbase.hbasestorage(“+”)的pigserver.registerquery(“source=load'”+inputfile+“”datos:bikes“,”-loadkey true“)“+”作为(id1:chararray,bikes:chararray) ;");