我编写了一个嵌入式 Pig 程序,它在我的机器上执行并在服务器(hadoop 机器)上执行查询并存储结果。但在这里我将 pig.property 文件提供给我的类路径。
可以不给 Pig.property 文件就写 Pig-Embedded 程序吗??
最佳答案
您可以使用 org.apache.pig.PigServer 从 Java 程序运行 pig 脚本。
PigServer pigServer = new PigServer(ExecType.MAPREDUCE);
pigServer.registerScript("scripts/test.pig");
需要类路径上的“pig.properties”。
fs.default.name=hdfs://:
mapred.job.tracker=:
或者将 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);
还检查 this
关于apache-pig - 无属性文件的嵌入式 Pig 程序,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/12258261/