我正在尝试从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");
}
}
暂无答案!
目前还没有任何答案,快来回答吧!