PigServer pigServer = new PigServer(ExecType.MAPREDUCE);
pigServer.registerScript("scripts/test.pig");
Requires 'pig.properties' on classpath.
fs.default.name=hdfs://<namenode-hostname>:<port>
mapred.job.tracker=<jobtracker-hostname>:<port>
Or pass an instance of java.util.Properties to PigServer constructor.
Properties props = new Properties();
props.setProperty("fs.default.name", "hdfs://<namenode-hostname>:<port>");
props.setProperty("mapred.job.tracker", "<jobtracker-hostname>:<port>");
PigServer pigServer = new PigServer(ExecType.MAPREDUCE, props);
3条答案
按热度按时间r1wp621o1#
您可以使用org.apache.pig.pigserver从java程序运行pig脚本:
希望这有帮助
iyfamqjs2#
当然你也可以用咕噜壳(我总是忘记这件事。)
在我们的网站上,我们使用了一个启动程序脚本,它准备了一个pig调用命令,如下所示:
你可以用
explain -script
在咕噜声中:援引
pig
将脚本调用 Package 为explain
它看起来像:6pp0gazn3#
为此,您可以使用pigrunner。
例如:
我发现需要以下运行时依赖项来避免noclassdeffounderror:
Jackson制图器
antlr运行时
Guava