pig-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Rohini Palaniswamy <roh...@apache.org>
Subject Re: How to execute pig script from java
Date Fri, 10 Aug 2018 20:41:22 GMT
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 <rohini@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 <rautatul44@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
>>
>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message