Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Pig, mail # user - Call Pig from Java


Copy link to this message
-
Re: Call Pig from Java
Harsh J 2010-08-05, 04:01
You need to use the class PigServer.

PigServer pigServer = new PigServer("mapreduce"); // Or "local" for local mode
pigServer.registerQuery("A = LOAD ...");
(...) // Your statements here.
pigServer.store("A", "filename");

On Thu, Aug 5, 2010 at 9:26 AM, Wenhao Xu <[EMAIL PROTECTED]> wrote:
> Hi all,
>   I am new to pig. I am wondering is there any recommended way to call Pig
> code from Java?
>   Is there any Java interface which can be called directly from Java and
> makes them work smoothly? It seems each keyword (filter, group, cogrape,
> generate) and data types in Pig can have a counterpart in Java by using
> Class, interface and data type. Is these Java interface available to Java
> programmers to use? If not, why not?
>    Thanks very much for help!
>
> regards,
> Wenhao
>
> --
> ~_~
>

--
Harsh J
www.harshj.com