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. def apply(triples: RDD[Triple]): RDD[Triple]

   

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

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

   triples

   the RDF triples

   returns

   the materialized set of RDF triples

   Definition Classes

   ForwardRuleReasoner

8. final def asInstanceOf[T0]: T0

   

   Definition Classes

   Any

9. def clone(): AnyRef

   

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

10. def computeTransitiveClosure(edges: Dataset[Triple]): Dataset[Triple]

    

    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

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

12. def computeTransitiveClosure(triples: RDD[Triple], predicate: Node): RDD[Triple]

    

    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

13. def computeTransitiveClosure(triples: RDD[Triple]): RDD[Triple]

    

    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

14. def computeTransitiveClosure(triples: Set[Triple]): Set[Triple]

    

    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

15. def computeTransitiveClosureDF(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

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

    

    Definition Classes

    TransitiveReasoner

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

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    AnyRef

22. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

26. def extractTriples(triples: RDD[Triple], subject: Option[Node], predicate: Option[Node], obj: Option[Node]): RDD[Triple]

    

    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

27. def extractTriples(triples: RDD[Triple], predicate: Node): RDD[Triple]

    

    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

28. def extractTriples(triples: Set[Triple], predicate: Node): Set[Triple]

    

    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

29. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

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

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

    

    Definition Classes

    AnyRef → Any

31. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

35. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

36. def log: Logger

    

    Attributes

    protected

    Definition Classes

    Logging

37. def logName: String

    

    Attributes

    protected

    Definition Classes

    Logging

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

    

    Definition Classes

    AnyRef

39. final def notify(): Unit

    

    Definition Classes

    AnyRef

40. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

41. val parallelism: Int

    

    Definition Classes

    TransitiveReasoner

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

    

    Definition Classes

    Profiler

43. val properties: Seq[Node]

    

    Definition Classes

    TransitiveReasoner

44. val sqlContext: SQLContext

    

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

    

    Definition Classes

    AnyRef

46. def toString(): String

    

    Definition Classes

    AnyRef → Any

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

50. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging