ForwardRuleReasonerRDFSDataframe

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)]

   

   Definition Classes

   TransitiveReasoner

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

   ForwardRuleReasonerRDFSDataframe → TransitiveReasoner → ForwardRuleReasoner

6. def apply(graph: RDFGraphDataFrame): RDFGraphDataFrame

   

7. final def asInstanceOf[T0]: T0

   

   Definition Classes

   Any

8. def clone(): AnyRef

   

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

9. 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

   Definition Classes

   TransitiveReasoner

10. 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

    Definition Classes

    TransitiveReasoner

11. 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

    Definition Classes

    TransitiveReasoner

12. 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

    Definition Classes

    TransitiveReasoner

13. 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

    Definition Classes

    TransitiveReasoner

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

    

    Definition Classes

    TransitiveReasoner

15. 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

    Definition Classes

    TransitiveReasoner

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    AnyRef

20. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

24. 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

25. 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

26. 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

27. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

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

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

    

    Definition Classes

    AnyRef → Any

29. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

33. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

34. def log: Logger

    

    Attributes

    protected

    Definition Classes

    Logging

35. def logName: String

    

    Attributes

    protected

    Definition Classes

    Logging

36. var log_: Logger

    

    Definition Classes

    Logging

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

    

    Definition Classes

    AnyRef

38. final def notify(): Unit

    

    Definition Classes

    AnyRef

39. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

40. val parallelism: Int

    

    Definition Classes

    TransitiveReasoner

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

    

    Definition Classes

    Profiler

42. val properties: Seq[String]

    

    Definition Classes

    TransitiveReasoner

43. val sqlContext: SQLContext

    

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

    

    Definition Classes

    AnyRef

45. def toString(): String

    

    Definition Classes

    AnyRef → Any

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

49. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging