在Java中运行Pig而不嵌入Pig脚本

您可以使用org.apache.pig.PigServer从Java程序运行Pig脚本。

PigServer pigServer = new PigServer(ExecType.MAPREDUCE);pigServer.registerscript("scripts/test.pig");

在类路径上需要“ pig.properties”。

fs.default.name=hdfs://<namenode-hostname>:<port>mapred.job.tracker=<jobtracker-hostname>:<port>

或将java.util.Properties的实例传递给PigServer构造函数。

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