May 2017
Intermediate to advanced
294 pages
7h 33m
English
scala> import org.apache.spark.graphx._
scala> val edgesFile = sc.textFile( "s3a://com.infoobjects.wiki/links",20)
scala> val edges = edgesFile.flatMap { line => val links = line.split("\\W+") val from = links(0) val to = links.tail for ( link <- to) yield (from,link) }.map( e => Edge(e._1.toLong,e._2.toLong,1))
scala> val verticesFile = sc.textFile ("s3a://com.infoobjects.wiki/nodes",20) ...Read now
Unlock full access