You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@spark.apache.org by qiaou <qi...@gmail.com> on 2014/11/12 07:31:13 UTC
How did the RDD.union work
Hi:
I got a problem with using the union method of RDD
things like this
I get a function like
def hbaseQuery(area:string):RDD[Result]= ???
when i use hbaseQuery('aa').union(hbaseQuery(‘bb’)).count() it returns 0
however when use like this sc.parallize(hbaseQuery('aa’).collect.toList ::: hbaseQuery(’bb’).collect.toList) it return the right value
obviously i have got an action after my transformation action ,but why it did not work
fyi
--
qiaou
已使用 Sparrow (http://www.sparrowmailapp.com/?sig)