Packages

o

org.apache.spark.graphx

GraphLoader

object GraphLoader extends Logging

Provides utilities for loading Graphs from files.

Source
GraphLoader.scala
Linear Supertypes
Logging, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. GraphLoader
  2. Logging
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. 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.

    Loads a graph from an edge list formatted file where each line contains two integers: a source id and a target id. Skips lines that begin with #.

    If desired the edges can be automatically oriented in the positive direction (source Id is less than target Id) by setting canonicalOrientation to true.

    sc

    SparkContext

    path

    the path to the file (e.g., /home/data/file or hdfs://file)

    canonicalOrientation

    whether to orient edges in the positive direction

    numEdgePartitions

    the number of partitions for the edge RDD Setting this value to -1 will use the default parallelism.

    edgeStorageLevel

    the desired storage level for the edge partitions

    vertexStorageLevel

    the desired storage level for the vertex partitions

    Example:
    1. Loads a file in the following format:

      # Comment Line
      # Source Id <\t> Target Id
      1   -5
      1    2
      2    7
      1    8