Advertisement
vitalijzad

Errore di compilazione su pattern matching con RDD

Jan 31st, 2018
89
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Scala 0.72 KB | None | 0 0
  1.   def computeContribs(tuples : RDD[(Int,List[Int])], ranks : RDD[(Int, Double)] ) : RDD[(Int, Double)] = {
  2.     val x = tuples.map{case(numpage,list)=>(numpage,(list,1.0/list.size))}
  3.     val joined = x.join(ranks)
  4.     val contribs = joined.flatMap{case(numPage,(pageList,size), rank) => pageList.map( y:Int=>(y,size) )}
  5.     contribs.reduceByKey(_+_)
  6.   }
  7.  
  8. /*
  9. [error] C:\Users\vital\Documents\spazi_lavoro\spark-examples\src\main\scala\pagerank\PageRankSpark.scala:11: constructor cannot be instantiated to expected type;
  10. [error]  found   : (T1, T2, T3)
  11. [error]  required: (Int, ((List[Int], Double), Double))
  12. [error]     val contribs = joined.flatMap{case(numPage,(pageList,size), rank) => pageList.map( y:Int=>(y,size) )}
  13. */
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement