TransitiveReasoner

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 addTransitivePairs[A, B](s: Set[(A, B)]): Set[(A, B)]

   

5. def apply(graph: RDFGraph): RDFGraph

   

   Applies forward chaining to the given RDF graph and returns a new RDF graph that contains all additional triples based on the underlying set of rules.

   Applies forward chaining to the given RDF graph and returns a new RDF graph that contains all additional triples based on the underlying set of rules.

   graph

   the RDF graph

   returns

   the materialized RDF graph

   Definition Classes

   TransitiveReasoner → ForwardRuleReasoner

6. final def asInstanceOf[T0]: T0

   

   Definition Classes

   Any

7. def clone(): AnyRef

   

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

8. def computeTransitiveClosure(edges: Dataset[RDFTriple]): Dataset[RDFTriple]

   

   Computes the transitive closure for a Dataframe of triples

   Computes the transitive closure for a Dataframe of triples

   edges

   the Dataframe of triples

   returns

   a Dataframe containing the transitive closure of the triples

9. def computeTransitiveClosure[A](edges: RDD[(A, A)])(implicit arg0: ClassTag[A]): RDD[(A, A)]

   

   Computes the transitive closure for an RDD of tuples

   Computes the transitive closure for an RDD of tuples

   edges

   the RDD of tuples

   returns

   an RDD containing the transitive closure of the tuples

10. def computeTransitiveClosure(triples: RDD[RDFTriple], predicate: String): RDD[RDFTriple]

    

    Computes the transitive closure for the given predicate on an RDD of triples.

    Computes the transitive closure for the given predicate on an RDD of triples.

    triples

    the RDD of triples

    predicate

    the predicate

    returns

    an RDD containing the transitive closure of the triples

11. def computeTransitiveClosure(triples: RDD[RDFTriple]): RDD[RDFTriple]

    

    Computes the transitive closure on an RDD of triples.

    Computes the transitive closure on an RDD of triples. Note, that the assumption is that all triples do have the same predicate.

    triples

    the RDD of triples

    returns

    an RDD containing the transitive closure of the triples

12. def computeTransitiveClosure(triples: Set[RDFTriple]): Set[RDFTriple]

    

    Computes the transitive closure on a set of triples, i.e.

    Computes the transitive closure on a set of triples, i.e. it is computed in-memory by the driver. Note, that the assumption is that all triples do have the same predicate.

    triples

    the set of triples

    returns

    a set containing the transitive closure of the triples

13. def computeTransitiveClosurePairs[A, B](s: Set[(A, B)]): Set[(A, B)]

    

14. def computeTransitiveClosureSemiNaive[A](edges: RDD[(A, A)])(implicit arg0: ClassTag[A]): RDD[(A, A)]

    

    Semi-naive computation of the transitive closure T for an RDD of tuples R=(x,y).

    Semi-naive computation of the transitive closure T for an RDD of tuples R=(x,y).

    (1) T = R
    (2) ∆T = R
    (3) while ∆T != ∅ do
    (4) ∆T = ∆T ◦ R − T
    (5) T = T ∪ ∆T
    (6) end

    edges

    the RDD of tuples (x,y)

    returns

    an RDD containing the transitive closure of the tuples

15. def debug(msg: ⇒ String, o: Any, os: Any*): Unit

    

    Definition Classes

    Logging

16. def debug(msg: ⇒ String, e: Throwable): Unit

    

    Definition Classes

    Logging

17. def debug(msg: ⇒ String): Unit

    

    Definition Classes

    Logging

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

    

    Definition Classes

    AnyRef

19. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

20. def error(msg: ⇒ String, o: Any, os: Any*): Unit

    

    Definition Classes

    Logging

21. def error(msg: ⇒ String, e: Throwable): Unit

    

    Definition Classes

    Logging

22. def error(msg: ⇒ String): Unit

    

    Definition Classes

    Logging

23. def extractTriples(triples: RDD[RDFTriple], subject: Option[String], predicate: Option[String], obj: Option[String]): RDD[RDFTriple]

    

    Extracts all triples that match the given subject, predicate and object if defined.

    Extracts all triples that match the given subject, predicate and object if defined.

    triples

    the RDD of triples

    subject

    the subject

    predicate

    the predicate

    obj

    the object

    returns

    the RDD of triples that match

    Definition Classes

    ForwardRuleReasoner

24. def extractTriples(triples: RDD[RDFTriple], predicate: String): RDD[RDFTriple]

    

    Extracts all triples for the given predicate.

    Extracts all triples for the given predicate.

    triples

    the RDD of triples

    predicate

    the predicate

    returns

    the RDD of triples that contain the predicate

    Definition Classes

    ForwardRuleReasoner

25. def extractTriples(triples: Set[RDFTriple], predicate: String): Set[RDFTriple]

    

    Extracts all triples for the given predicate.

    Extracts all triples for the given predicate.

    triples

    the triples

    predicate

    the predicate

    returns

    the set of triples that contain the predicate

    Definition Classes

    ForwardRuleReasoner

26. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

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

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

    

    Definition Classes

    AnyRef → Any

28. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

29. def info(msg: ⇒ String, o: Any, os: Any*): Unit

    

    Definition Classes

    Logging

30. def info(msg: ⇒ String, e: Throwable): Unit

    

    Definition Classes

    Logging

31. def info(msg: ⇒ String): Unit

    

    Definition Classes

    Logging

32. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

33. def log: Logger

    

    Attributes

    protected

    Definition Classes

    Logging

34. def logName: String

    

    Attributes

    protected

    Definition Classes

    Logging

35. var log_: Logger

    

    Definition Classes

    Logging

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

    

    Definition Classes

    AnyRef

37. final def notify(): Unit

    

    Definition Classes

    AnyRef

38. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

39. val parallelism: Int

    

40. def profile[R](block: ⇒ R): R

    

    Definition Classes

    Profiler

41. val properties: Seq[String]

    

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

    

    Definition Classes

    AnyRef

43. def toString(): String

    

    Definition Classes

    AnyRef → Any

44. def trace(msg: ⇒ String, o: Any, os: Any*): Unit

    

    Definition Classes

    Logging

45. def trace(msg: ⇒ String, e: Throwable): Unit

    

    Definition Classes

    Logging

46. def trace(msg: ⇒ String): Unit

    

    Definition Classes

    Logging

47. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

50. def warn(msg: ⇒ String, o: Any, os: Any*): Unit

    

    Definition Classes

    Logging

51. def warn(msg: ⇒ String, e: Throwable): Unit

    

    Definition Classes

    Logging

52. def warn(msg: ⇒ String): Unit

    

    Definition Classes

    Logging