在Java中运行Pig而不嵌入Pig脚本

作者: 春风助手
发布时间: 2024-12-24 03:51:08 (26天前)

2 条回复

1#
回复此人
只怕再见是故人 | 2020-08-13 16-37

您可以使用org.apache.pig.PigServer从Java程序运行Pig脚本。 ``` PigServer pigServer = new PigServer(ExecType.MAPREDUCE); pigServer.registerScript("scripts/test.pig"); ``` 在类路径上需要“ pig.properties”。 ``` fs.default.name=hdfs://<namenode-hostname>:<port> mapred.job.tracker=<jobtracker-hostname>:<port> ``` 或将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); ```

编辑

登录后才能参与评论