Pass RDD to functions

2014-11-12 Thread Deep Pradhan 
Hi,
Can we pass RDD to functions?
Like, can we do the following?

*def func (temp: RDD[String]):RDD[String] = {*
*//body of the function*
*}*


Thank You

Re: Pass RDD to functions

2014-11-12 Thread Akhil Das 
Yes you can create more and more pipelines with your RDDs

Thanks
Best Regards

On Wed, Nov 12, 2014 at 3:24 PM, Deep Pradhan pradhandeep1...@gmail.com
wrote:

 Hi,
 Can we pass RDD to functions?
 Like, can we do the following?

 *def func (temp: RDD[String]):RDD[String] = {*
 *//body of the function*
 *}*


 Thank You

Re: Pass RDD to functions

2014-11-12 Thread qinwei 






I think it‘s ok，feel free to treat RDD like common object


qinwei
 From: Deep PradhanDate: 2014-11-12 18:24To: user@spark.apache.orgSubject: Pass 
RDD to functionsHi, Can we pass RDD to functions?Like, can we do the following?
def func (temp: RDD[String]):RDD[String] = {//body of the function}

Thank You