Java&Pig使用PigServer将参数传递给Pig脚本

我有这个Java程序,它以MapReduce模式执行一个Pig脚本.这是代码：

import java.io.IOException;
import java.util.Properties;
import org.apache.pig.ExecType;
import org.apache.pig.PigServer;
import org.apache.pig.backend.executionengine.ExecException;
public class pigCV {
public static void main(String args[]){
PigServer pigServer;
try {
Properties props = new Properties();
props.setProperty("fs.default.name", "hdfs://hdfs://localhost:8022");
props.setProperty("mapred.job.tracker", "localhost:8021");
pigServer = new PigServer(ExecType.MAPREDUCE, props);
pigServer.registerScript("Desktop/text_v3.pig");
}
catch (ExecException e) { e.printStackTrace(); }
catch (IOException e) { e.printStackTrace(); }
}
}


通过linux命令行,我可以使用以下命令将参数传递给Pig脚本：

pig -f “Desktop/text_v3.pig” -param param1=value1 -param2=value2

但是使用PigServer,我没有找到如何做的.

您知道如何解决该问题吗？

谢谢.

解决方法:

您可以使用此版本的registerScript方法：

public void registerScript(String fileName, Map params)


java docs的解释如下：“注册一个Pig脚本文件.文件中的参数将替换为params中的值.”