TripleOps

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 add(triples: RDD[Triple], triple: Triple): RDD[Triple]

   

   Add a statement to the current RDF graph.

   Add a statement to the current RDF graph.

   triples

   RDD of RDF graph

   triple

   the triple to be added.

   returns

   new RDD of triples containing this statement.

5. def addAll(triples: RDD[Triple], triple: Seq[Triple]): RDD[Triple]

   

   Add a list of statements to the current RDF graph.

   Add a list of statements to the current RDF graph.

   triples

   RDD of RDF graph

   triple

   the list of triples to be added.

   returns

   new RDD of triples containing this list of statements.

6. final def asInstanceOf[T0]: T0

   

   Definition Classes

   Any

7. def clone(): AnyRef

   

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

8. def contains(triples: RDD[Triple], triple: Triple): Boolean

   

   Determine if a triple is present in this RDF graph.

   Determine if a triple is present in this RDF graph.

   triples

   RDD of triples

   triple

   the triple to be checked

   returns

   true if the statement s is in this RDF graph, false otherwise

9. def contains(triples: RDD[Triple], subject: Option[Node] = None, predicate: Option[Node] = None, object: Option[Node] = None): Boolean

   

   Determine whether this RDF graph contains any triples with a given (subject, predicate, object) pattern.

   Determine whether this RDF graph contains any triples with a given (subject, predicate, object) pattern.

   triples

   RDD of triples

   subject

   the subject (None for any)

   predicate

   the predicate (None for any)

   object

   the object (None for any)

   returns

   true if there exists within this RDF graph a triple with (S, P, O) pattern, false otherwise

10. def containsAll(triples: RDD[Triple], other: RDD[Triple]): Boolean

    

    Determine if all of the statements in an RDF graph are also contained in this RDF graph.

    Determine if all of the statements in an RDF graph are also contained in this RDF graph.

    triples

    RDD of triples

    other

    the other RDF graph containing the statements to be tested

    returns

    true if all of the statements in RDF graph are also contained in this RDF graph and false otherwise.

11. def containsAny(triples: RDD[Triple], other: RDD[Triple]): Boolean

    

    Determine if any of the triples in an RDF graph are also contained in this RDF graph.

    Determine if any of the triples in an RDF graph are also contained in this RDF graph.

    triples

    RDD of triples

    other

    the other RDF graph containing the statements to be tested

    returns

    true if any of the statements in RDF graph are also contained in this RDF graph and false otherwise.

12. def difference(triples: RDD[Triple], other: RDD[Triple]): RDD[Triple]

    

    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.

    triples

    RDD of RDF graph

    other

    the other RDF graph

    returns

    the difference of both RDF graphs

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

    

    Definition Classes

    AnyRef

14. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

15. def filterObjects(triples: RDD[Triple], func: (Node) ⇒ Boolean): RDD[Triple]

    

    Filter out the objects from a given RDD[Triple], based on a specific function @func .

    Filter out the objects from a given RDD[Triple], based on a specific function @func .

    triples

    RDD of triples.

    func

    a partial funtion.

    returns

    RDD[Triple] a subset of the given RDD.

16. def filterPredicates(triples: RDD[Triple], func: (Node) ⇒ Boolean): RDD[Triple]

    

    Filter out the predicates from a given RDD[Triple], based on a specific function @func .

    Filter out the predicates from a given RDD[Triple], based on a specific function @func .

    triples

    RDD of triples.

    func

    a partial funtion.

    returns

    RDD[Triple] a subset of the given RDD.

17. def filterSubjects(triples: RDD[Triple], func: (Node) ⇒ Boolean): RDD[Triple]

    

    Filter out the subject from a given RDD[Triple], based on a specific function @func .

    Filter out the subject from a given RDD[Triple], based on a specific function @func .

    triples

    RDD of triples.

    func

    a partial funtion.

    returns

    RDD[Triple] a subset of the given RDD.

18. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

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

19. def find(triples: RDD[Triple], triple: Triple): RDD[Triple]

    

    Returns an RDD of triples that match with the given input.

    Returns an RDD of triples that match with the given input.

    triples

    RDD of triples

    triple

    the triple to be checked

    returns

    RDD of triples that match the given input

20. def find(triples: RDD[Triple], subject: Option[Node] = None, predicate: Option[Node] = None, object: Option[Node] = None): RDD[Triple]

    

    Returns an RDD of triples that match with the given input.

    Returns an RDD of triples that match with the given input.

    triples

    RDD of triples

    subject

    the subject

    predicate

    the predicate

    object

    the object

    returns

    RDD of triples

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

    

    Definition Classes

    AnyRef → Any

22. def getObjects(triples: RDD[Triple]): RDD[Node]

    

    Get objects.

    Get objects.

    triples

    RDD of triples.

    returns

    RDD[Node] which contains list of the objects.

23. def getPredicates(triples: RDD[Triple]): RDD[Node]

    

    Get predicates.

    Get predicates.

    triples

    RDD of triples.

    returns

    RDD[Node] which contains list of the predicates.

24. def getSubjects(triples: RDD[Triple]): RDD[Node]

    

    Get subjects.

    Get subjects.

    triples

    RDD of triples.

    returns

    RDD[Node] which contains list of the subjects.

25. def getTriples(triples: RDD[Triple]): RDD[Triple]

    

    Get triples.

    Get triples.

    triples

    RDD of triples.

    returns

    RDD[Triple] which contains list of the triples.

26. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

27. def intersection(triples: RDD[Triple], other: RDD[Triple]): RDD[Triple]

    

    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.

    triples

    RDD of RDF graph

    other

    the other RDF graph

    returns

    the intersection of both RDF graphs

28. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

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

    

    Definition Classes

    AnyRef

30. final def notify(): Unit

    

    Definition Classes

    AnyRef

31. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

32. def remove(triples: RDD[Triple], triple: Triple): RDD[Triple]

    

    Removes a statement from the current RDF graph.

    Removes a statement from the current RDF graph. The statement with the same subject, predicate and object as that supplied will be removed from the model.

    triples

    RDD of RDF graph

    triple

    the statement to be removed.

    returns

    new RDD of triples without this statement.

33. def removeAll(triples: RDD[Triple], triple: Seq[Triple]): RDD[Triple]

    

    Removes all the statements from the current RDF graph.

    Removes all the statements from the current RDF graph. The statements with the same subject, predicate and object as those supplied will be removed from the model.

    triples

    RDD of RDF graph

    triple

    the list of statements to be removed.

    returns

    new RDD of triples without these statements.

34. def saveAsNTriplesFile(triples: RDD[Triple], path: String): Unit

    

    Write N-Triples from a given RDD of triples

    Write N-Triples from a given RDD of triples

    triples

    RDD of RDF graph

    path

    path to the file containing N-Triples

35. def size(triples: RDD[Triple]): Long

    

    Return the number of triples.

    Return the number of triples.

    triples

    RDD of triples

    returns

    the number of triples

36. var spark: SparkSession

    

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

    

    Definition Classes

    AnyRef

38. def toDF(triples: RDD[Triple]): DataFrame

    

    Convert a RDD[Triple] into a DataFrame.

    Convert a RDD[Triple] into a DataFrame.

    triples

    RDD of triples.

    returns

    a DataFrame of triples.

39. def toDS(triples: RDD[Triple]): Dataset[Triple]

    

    Convert an RDD of Triple into a Dataset of Triple.

    Convert an RDD of Triple into a Dataset of Triple.

    triples

    RDD of triples.

    returns

    a Dataset of triples.

40. def toString(): String

    

    Definition Classes

    AnyRef → Any

41. def union(triples: RDD[Triple], other: RDD[Triple]): RDD[Triple]

    

    Return the union of this RDF graph and another one.

    Return the union of this RDF graph and another one.

    triples

    RDD of RDF graph

    other

    the other RDF graph

    returns

    graph (union of both)

42. def unionAll(triples: RDD[Triple], others: Seq[RDD[Triple]]): RDD[Triple]

    

    Return the union all of RDF graphs.

    Return the union all of RDF graphs.

    triples

    RDD of RDF graph

    others

    sequence of RDDs of other RDF graph

    returns

    graph (union of all)

43. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )