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

Reply via email to