Pig does not have any server. The client directly launches jobs on the YARN
cluster. You can just use the APIs in
http://pig.apache.org/docs/r0.17.0/api/org/apache/pig/PigServer.html to
execute scripts from your java program.

On Sun, Jul 29, 2018 at 8:24 PM, Atul Raut <rautatu...@gmail.com> wrote:

> How to execute pig script from java class.
>
> I need to submit Pig script from my java application to the Pig server
> (This may be on any remote location) and that Pig server will execute that
> script and return the result to my java application.
>
>
>
> Following is my source,
>
> public static void main(String[] args) throws Exception
> { System.setProperty("hadoop.home.dir",
> "/Pig/hadoop-common-2.2.0-bin-master/"); Properties props = new
> Properties(); props.setProperty("fs.default.name", "hdfs://
> 192.168.102.179:8020"); props.setProperty("mapred.job.tracker", "
> 192.168.102.179:8021");
> props.setProperty("pig.use.overriden.hadoop.configs", "true"); PigServer
> pig = new PigServer(ExecType.MAPREDUCE, props); pig.debugOn();
> pig.registerScript("A = LOAD '/apps/employee/sample.txt' USING
> PigStorage();"); }
>
>
>
> Regards,
> Atul Raut
>

Reply via email to