May 2017
Intermediate to advanced
294 pages
7h 33m
English
$ spark-shell
scala> import org.apache.spark.graphx._
scala> val edgesFile = sc.textFile( "hdfs://localhost:9000/user/hduser/data/cc/edges.csv")
scala> val edges = edgesFile.map(_.split(",")).map(e => Edge(e(0).toLong,e(1).toLong,e(2)))
scala> val verticesFile = sc.textFile( "hdfs://localhost:9000/user/hduser/data/cc/nodes.csv")
scala> val vertices = verticesFile.map(_.split(",")).map( e => (e(0).toLong,e(1)))
scala> val graph = Graph(vertices,edges)
Read now
Unlock full access