图构造者

GraphX提供了几种方式从RDD或者磁盘上的顶点和边集合构造图。默认情况下，没有哪个图构造者为图的边重新分区，而是把边保留在默认的分区中（例如HDFS中它们的原始块）。@groupEdges((ED,ED">Graph.groupEdges⇒ED):Graph[VD,ED])
需要重新分区图，因为它假定相同的边将会被分配到同一个分区，所以你必须在调用groupEdges之前调用@partitionBy(PartitionStrategy">Graph.partitionBy:Graph[VD,ED])

  1. object GraphLoader {
  2.   def edgeListFile(
  3.       sc: SparkContext,
  4.       path: String,
  5.       canonicalOrientation: Boolean = false,
  6.       minEdgePartitions: Int = 1)
  7.     : Graph[Int, Int]
  8. }

@edgeListFile(SparkContext,String,Boolean,Int">GraphLoader.edgeListFile:Graph[Int,Int])
提供了一个方式从磁盘上的边列表中加载一个图。它解析如下形式（源顶点ID，目标顶点ID）的连接表，跳过以#开头的注释行。

  1. # This is a comment
  2. 2 1
  3. 4 1
  4. 1 2

它从指定的边创建一个图，自动地创建边提及的所有顶点。所有的顶点和边的属性默认都是1。canonicalOrientation参数允许重定向正方向(srcId < dstId)的边。这在connected components
算法中需要用到。minEdgePartitions参数指定生成的边分区的最少数量。边分区可能比指定的分区更多，例如，一个HDFS文件包含更多的块。

  1. object Graph {
  2.   def apply[VD, ED](
  3.       vertices: RDD[(VertexId, VD)],
  4.       edges: RDD[Edge[ED]],
  5.       defaultVertexAttr: VD = null)
  6.     : Graph[VD, ED]
  7.   def fromEdges[VD, ED](
  8.       edges: RDD[Edge[ED]],
  9.       defaultValue: VD): Graph[VD, ED]
  10.   def fromEdgeTuples[VD](
  11.       rawEdges: RDD[(VertexId, VertexId)],
  12.       defaultValue: VD,
  13.       uniqueEdges: Option[PartitionStrategy] = None): Graph[VD, Int]
  14. }

@apply[VD,ED](RDD[(VertexId,VD">Graph.apply],RDD[Edge[ED]],VD)(ClassTag[VD],ClassTag[ED]):Graph[VD,ED])
允许从顶点和边的RDD上创建一个图。重复的顶点可以任意的选择其中一个，在边RDD中而不是在顶点RDD中发现的顶点分配默认的属性。

@fromEdges[VD,ED](RDD[Edge[ED]],VD">Graph.fromEdges(ClassTag[VD],ClassTag[ED]):Graph[VD,ED])
允许仅仅从一个边RDD上创建一个图，它自动地创建边提及的顶点，并分配这些顶点默认的值。

@fromEdgeTuples[VD](RDD[(VertexId,VertexId">Graph.fromEdgeTuples],VD,Option[PartitionStrategy])(ClassTag[VD]):Graph[VD,Int])
允许仅仅从一个边元组组成的RDD上创建一个图。分配给边的值为1。它自动地创建边提及的顶点，并分配这些顶点默认的值。它还支持删除边。为了删除边，需要传递一个PartitionStrategy
为值的Some作为uniqueEdges参数（如uniqueEdges = Some(PartitionStrategy.RandomVertexCut)）。分配相同的边到同一个分区从而使它们可以被删除，一个分区策略是必须的。