Class

net.sansa_stack.rdf.spark.model

GraphOperations

Related Doc: package model

Permalink

implicit class GraphOperations extends Logging

Adds methods, astTriple, find, size to Node that allows to different operations to it.

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

Instance Constructors

  1. new GraphOperations(graph: Graph[Node, Node])

    Permalink

Value Members

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

    Permalink
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  5. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  6. def difference(other: Graph[Node, Node]): Graph[Node, Node]

    Permalink

    Returns a new RDF graph that contains the intersection of the current RDF graph with the given RDF graph.

    Returns a new RDF graph that contains the intersection of the current RDF graph with the given RDF graph.

    other

    the other RDF graph

    returns

    the intersection of both RDF graphs

    See also

    net.sansa_stack.rdf.spark.graph.GraphOps.difference

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

    Permalink
    Definition Classes
    AnyRef
  8. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  9. def filterObjects(func: (Node) ⇒ Boolean): Graph[Node, Node]

    Permalink

    Filter out the objects from a given graph, based on a specific function @func .

    Filter out the objects from a given graph, based on a specific function @func .

    func

    a partial funtion.

    returns

    Node] a subset of the given graph.

    See also

    net.sansa_stack.rdf.spark.graph.GraphOps.filterObjects

  10. def filterPredicates(func: (Node) ⇒ Boolean): Graph[Node, Node]

    Permalink

    Filter out the predicates from a given graph, based on a specific function @func .

    Filter out the predicates from a given graph, based on a specific function @func .

    func

    a partial funtion.

    returns

    Node] a subset of the given graph.

    See also

    net.sansa_stack.rdf.spark.graph.GraphOps.filterPredicates

  11. def filterSubjects(func: (Node) ⇒ Boolean): Graph[Node, Node]

    Permalink

    Filter out the subject from a given graph, based on a specific function @func .

    Filter out the subject from a given graph, based on a specific function @func .

    func

    a partial funtion.

    returns

    Node] a subset of the given graph.

    See also

    net.sansa_stack.rdf.spark.graph.GraphOps.filterSubjects

  12. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  13. def find(subject: Node, predicate: Node, object: Node): Graph[Node, Node]

    Permalink

    Finds triplets of a given graph.

    Finds triplets of a given graph.

    returns

    graph which contains subset of the reduced graph.

    See also

    net.sansa_stack.rdf.spark.graph.GraphOps.find

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

    Permalink
    Definition Classes
    AnyRef → Any
  15. def getObjects(): RDD[Node]

    Permalink

    Gets objects of a given graph.

    Gets objects of a given graph.

    returns

    RDD[Node from the given graph.

    See also

    net.sansa_stack.rdf.spark.graph.GraphOps.getObjects

  16. def getPredicates(): RDD[Node]

    Permalink

    Gets predicates of a given graph.

    Gets predicates of a given graph.

    returns

    RDD[Node from the given graph.

    See also

    net.sansa_stack.rdf.spark.graph.GraphOps.getPredicates

  17. def getSubjects(): RDD[Node]

    Permalink

    Gets subjects of a given graph.

    Gets subjects of a given graph.

    returns

    RDD[Node from the given graph.

    See also

    net.sansa_stack.rdf.spark.graph.GraphOps.getSubjects

  18. def getTriples(): RDD[Triple]

    Permalink

    Gets triples of a given graph.

    Gets triples of a given graph.

    returns

    RDD[Triple from the given graph.

    See also

    net.sansa_stack.rdf.spark.graph.GraphOps.getTriples

  19. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  20. def hierarcyDepth(): Graph[(VertexId, Int, Node), Node]

    Permalink

    Returns the lever at which vertex stands in the hierarchy.

  21. def intersection(other: Graph[Node, Node]): Graph[Node, Node]

    Permalink

    Returns a new RDF graph that contains the difference between the current RDF graph and the given RDF graph.

    Returns a new RDF graph that contains the difference between the current RDF graph and the given RDF graph.

    other

    the other RDF graph

    returns

    the difference of both RDF graphs

    See also

    net.sansa_stack.rdf.spark.graph.GraphOps.intersection

  22. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  23. def isTraceEnabled(): Boolean

    Permalink
    Attributes
    protected
    Definition Classes
    Logging
  24. def log: Logger

    Permalink
    Attributes
    protected
    Definition Classes
    Logging
  25. def logDebug(msg: ⇒ String, throwable: Throwable): Unit

    Permalink
    Attributes
    protected
    Definition Classes
    Logging
  26. def logDebug(msg: ⇒ String): Unit

    Permalink
    Attributes
    protected
    Definition Classes
    Logging
  27. def logError(msg: ⇒ String, throwable: Throwable): Unit

    Permalink
    Attributes
    protected
    Definition Classes
    Logging
  28. def logError(msg: ⇒ String): Unit

    Permalink
    Attributes
    protected
    Definition Classes
    Logging
  29. def logInfo(msg: ⇒ String, throwable: Throwable): Unit

    Permalink
    Attributes
    protected
    Definition Classes
    Logging
  30. def logInfo(msg: ⇒ String): Unit

    Permalink
    Attributes
    protected
    Definition Classes
    Logging
  31. def logName: String

    Permalink
    Attributes
    protected
    Definition Classes
    Logging
  32. def logTrace(msg: ⇒ String, throwable: Throwable): Unit

    Permalink
    Attributes
    protected
    Definition Classes
    Logging
  33. def logTrace(msg: ⇒ String): Unit

    Permalink
    Attributes
    protected
    Definition Classes
    Logging
  34. def logWarning(msg: ⇒ String, throwable: Throwable): Unit

    Permalink
    Attributes
    protected
    Definition Classes
    Logging
  35. def logWarning(msg: ⇒ String): Unit

    Permalink
    Attributes
    protected
    Definition Classes
    Logging
  36. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  37. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
  38. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
  39. def saveGraphToJson(output: String): Unit

    Permalink

    Save the Graph to JSON format

    Save the Graph to JSON format

    output

    the output

  40. def size(): Long

    Permalink

    Compute the size of the graph

    Compute the size of the graph

    returns

    the number of edges in the graph.

    See also

    net.sansa_stack.rdf.spark.graph.GraphOps.size

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

    Permalink
    Definition Classes
    AnyRef
  42. def toDF(): DataFrame

    Permalink

    Convert a graph into a DataFrame.

    Convert a graph into a DataFrame.

    returns

    a DataFrame of triples.

    See also

    net.sansa_stack.rdf.spark.graph.GraphOps.toDF

  43. def toDS(): Dataset[Triple]

    Permalink

    Convert a graph into a Dataset of Triple.

    Convert a graph into a Dataset of Triple.

    returns

    a Dataset of triples.

    See also

    net.sansa_stack.rdf.spark.graph.GraphOps.toDS

  44. def toRDD(): RDD[Triple]

    Permalink

    Convert a graph into a RDD of Triple.

    Convert a graph into a RDD of Triple.

    returns

    a RDD of triples.

    See also

    net.sansa_stack.rdf.spark.graph.GraphOps.toRDD

  45. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any
  46. def union(other: Graph[Node, Node]): Graph[Node, Node]

    Permalink

    Return the union of this graph and another one.

    Return the union of this graph and another one.

    other

    of the other graph

    returns

    graph (union of all)

    See also

    net.sansa_stack.rdf.spark.graph.GraphOps.union

  47. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  48. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  49. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from Logging

Inherited from AnyRef

Inherited from Any

Ungrouped