GraphLoader Object
Provides utilities for loading Graphs from files.
def edgeListFile(sc: SparkContext, path: String, canonicalOrientation: Boolean = false, numEdgePartitions: Int = 1, edgeStorageLevel: StorageLevel = StorageLevel.MEMORY_ONLY, vertexStorageLevel: StorageLevel = StorageLevel.MEMORY_ONLY): Graph[Int, Int]
Loads a graph from an edge list formatted file where each line contains two integers: a source id and a target id.
Example:
1
val graph = GraphLoader.edgeListFile(sc, "file:///home/dv6/spark/spark/data/graphx/followers.txt")
Copied!
Reference:
https://github.com/apache/spark/blob/v2.4.5/graphx/src/main/scala/org/apache/spark/graphx/GraphLoader.scala
Last modified 1yr ago
Copy link