java远程执行pig脚本

ohfgkhjo  于 2021-06-02  发布在  Hadoop
关注(0)|答案(0)|浏览(192)

我正在尝试从java执行pig脚本,以便它可以连接到集群并执行逻辑。我关注这个链接,但这将如何连接我的集群,因为我没有提到的网址。如何远程连接?
代码:

import java.io.IOException;
import org.apache.pig.PigServer;
public class idlocal{ 
    public static void main(String[] args) {
        try {
        PigServer pigServer = new PigServer("local");
        runIdQuery(pigServer, "passwd");
        }
        catch(Exception e) {
        }
    }
    public static void runIdQuery(PigServer pigServer, String inputFile) throws IOException {
        pigServer.registerQuery("A = load '" + inputFile + "' using PigStorage(':');");
        pigServer.registerQuery("B = foreach A generate $0 as id;");
        pigServer.store("B", "id.out");
    }
}

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题