What you are missing in your source code is call to openIterator() or store() to retrieve the results.
http://pig.apache.org/docs/r0.17.0/api/org/apache/pig/PigServer.html The programmer then registers queries using registerQuery() and retrieves results using openIterator() or store() On Fri, Aug 10, 2018 at 1:36 PM, Rohini Palaniswamy <roh...@apache.org> wrote: > 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 >> > >
