PIG to SPARK

[suman bharadwaj]

Hi,

How can i call pig script using SPARK. Can I use rdd.pipe() here ?

And can anyone share sample implementation of rdd.pipe () and if you can
explain how rdd.pipe() works, it would really really help.

Regards,
SB