2

我有这个 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(); }

}


}

问题是输出非常冗长。

所以我想知道这是否可以在静默模式下运行脚本。

谢谢你的帮助。

4

1 回答 1

1

我认为不PigServer支持在静默模式下运行。但是,您可以编写 java 代码来拦截stdin和/或stdout然后编写代码来决定将哪些内容打印到屏幕以及忽略哪些内容或将哪些内容写入文件。此链接中有一个如何执行此操作的示例。

于 2013-07-16T14:22:29.327 回答