WriteGraph

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. def apply(ds: Array[Row], gexfPath: String): Boolean

   

5. def apply(rdd: RDD[((String, String, String), Int)], gexfPath: String): Boolean

   

   Writes graph nodes and edges to file.

   Writes graph nodes and edges to file.

   rdd

   RDD of elements in format ((datestring, source, target), count)

   gexfPath

   output file

   returns

   Unit().

6. def asGexf(data: Array[Row], gexfPath: String): Boolean

   

   Produces the GEXF output from an Array[Row] and outputs it to gexfPath.

   Produces the GEXF output from an Array[Row] and outputs it to gexfPath.

   data

   a Dataset[Row] of elements in format (datestring, source, target, count)

   gexfPath

   output file

   returns

   true on success.

7. def asGexf(rdd: RDD[((String, String, String), Int)], gexfPath: String): Boolean

   

   Produces the GEXF output from a RDD of tuples and outputs it to gexfPath.

   Produces the GEXF output from a RDD of tuples and outputs it to gexfPath.

   rdd

   a RDD of elements in format ((datestring, source, target), count)

   gexfPath

   output file

   returns

   true on success.

8. def asGraphml(rdd: RDD[((String, String, String), Int)], graphmlPath: String): Boolean

   

9. final def asInstanceOf[T0]: T0

   

   Definition Classes

   Any

10. def clone(): AnyRef

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

11. val directedChunk: String

    

12. val edgeEnd: String

    

13. def edgeNodes(rdd: RDD[((String, String, String), Int)]): RDD[(String, Long, Long, Int)]

    

    Produces uniqueIds for edge lists from a flatMapped rdd, using nodesWithIds

    Produces uniqueIds for edge lists from a flatMapped rdd, using nodesWithIds

    rdd

    an RDD of elements in format ((datestring, source, target), count)

    returns

    an RDD in format (date, sourceid, destinationid, count)

14. val edgeStart: String

    

15. val endAttribute: String

    

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

    

    Definition Classes

    AnyRef

17. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

18. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

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

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

    

    Definition Classes

    AnyRef → Any

20. val gexfHeader: String

    

21. val graphmlHeader: String

    

22. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

23. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

24. val labelStart: String

    

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

    

    Definition Classes

    AnyRef

26. def nodeIdFromLabel(id: Option[(String, Long)]): Long

    

    Produces the id from Nodelookup

    Produces the id from Nodelookup

    id

    an Option containing the lookup.

    returns

    a long representing the id or -1 if no id exists from the lookup.

27. def nodeLookup(rdd: RDD[(String, Long)], lookup: String): Option[(String, Long)]

    

    Produces the (label, id) combination from a nodeslist of an RDD that has the same label as lookup.

    Produces the (label, id) combination from a nodeslist of an RDD that has the same label as lookup.

    rdd

    an RDD of elements in format ((datestring, source, target), count)

    lookup

    the label to lookup.

    returns

    an Option containing Some(Label, UniqueId) or None

28. val nodeStart: String

    

29. def nodesWithIds(rdd: RDD[((String, String, String), Int)]): RDD[(String, Long)]

    

    Produces a zipped RDD with ids and labels from an network-based RDD, rdd.

    Produces a zipped RDD with ids and labels from an network-based RDD, rdd.

    rdd

    a RDD of elements in format ((datestring, source, target), count)

    returns

    an RDD containing (Label, UniqueId)

30. final def notify(): Unit

    

    Definition Classes

    AnyRef

31. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

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

    

    Definition Classes

    AnyRef

33. val targetChunk: String

    

34. def toString(): String

    

    Definition Classes

    AnyRef → Any

35. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

38. val xmlHeader: String