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
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
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
