PSE

Value Members

1. final def !=(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

2. final def ##(): Int

   

   Definition Classes

   AnyRef → Any

3. final def ==(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

4. val APP_NAME: String

   

5. val EXEC_NAME: String

   

6. val VERSION: String

   

7. final def asInstanceOf[T0]: T0

   

   Definition Classes

   Any

8. def clone(): AnyRef

   

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

9. def enumerateSubgraphs(partPath: String, patternString: String, numColors: Short, numNodes: Broadcast[Long], sc: SparkContext): RDD[Array[Long]]

   

   Find subgraphs that match a query graph.

   Find subgraphs that match a query graph.

   partPath

   partitioned file path

   patternString

   the binary string of a query graph

   numColors

   the number of colors

   numNodes

   the number of nodes in the input graph

   sc

   spark context

10. final def eq(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

11. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

12. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

13. final def getClass(): Class[_]

    

    Definition Classes

    AnyRef → Any

14. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

15. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

16. def loadAdj(graphPath: Path, adj: Array[Array[Int]], localColor_src: Int, localColor_dst: Int, numColors: Int, fs: FileSystem): Unit

    

    load a graph of an adj format.

    load a graph of an adj format.

    graphPath

    graph file path

    adj

    to contain graph

    localColor_src

    the color of source nodes

    localColor_dst

    the color of destination nodes

    numColors

    the number of colors

    fs

    hadoop file system

17. final def ne(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

18. final def notify(): Unit

    

    Definition Classes

    AnyRef

19. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

20. def partitionGraph(inputPath: String, partPath: String, numColors: Short, sc: SparkContext): Unit

    

    partition the input graph.

    partition the input graph. The partitioned graph are stored in partPath A partition with colors i and j is stored in partPath/edgeset-{i*numColors + j} as a binary file whose format is as follows: node1 #neighbors-of-node1 neighbor1 neighbor2 ... node2 #neighbors-of-node2 neighbor1 ...

    inputPath

    input file path

    partPath

    partition file path

    numColors

    the number of colors

    sc

    spark context

21. def printGC(): Unit

    

    print gc type

22. def run(inputPath: String, patternString: String, numColors: Short, sc: SparkContext): RDD[Array[Long]]

    

    submit the spark job.

    submit the spark job.

    inputPath

    input file path

    patternString

    the binary string of a query graph

    numColors

    the number of colors

    sc

    spark context

    returns

    an RDD containing triangles

23. def runByCLI(args: Array[String]): Unit

    

    run by command line interpace

24. final def synchronized[T0](arg0: ⇒ T0): T0

    

    Definition Classes

    AnyRef

25. def toString(): String

    

    Definition Classes

    AnyRef → Any

26. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

27. final def wait(arg0: Long, arg1: Int): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

28. final def wait(arg0: Long): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )