Please send your call stack with the full description of the exception .
> On 10 Dec 2015, at 12:10, Бобров Виктор <ma...@bk.ru> wrote:
>
> Hi, I can’t filter my rdd.
>
> def filter1(tp: ((Array[String], Int), (Array[String], Int))): Boolean= {
> tp._1._2 > tp._2._2
> }
> val mail_rdd = sc.parallelize(A.toSeq).cache()
> val step1 = mail_rdd.cartesian(mail_rdd)
> val step2 = step1.filter(filter1)
>
> Get error “Class not found”. What I’m doing wrong ? Thanks for help.
>
>
>
