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 addTransitive(triples: Set[Triple]): Set[Triple]

   

5. final def asInstanceOf[T0]: T0

   

   Definition Classes

   Any

6. def clone(): AnyRef

   

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

7. def computeTransitiveClosure[A](edges: DataSet[(A, A)])(implicit arg0: ClassTag[A], arg1: TypeInformation[A]): DataSet[(A, A)]

   

   Computes the transitive closure for a DataSet of tuples

   Computes the transitive closure for a DataSet of tuples

   edges

   the DataSet of tuples

   returns

   a tuples containing the transitive closure of the tuples

8. def computeTransitiveClosure(triples: DataSet[Triple]): DataSet[Triple]

   

   Computes the transitive closure on a DataSet of triples.

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

   triples

   the DataSet of triples

   returns

   a DataSet containing the transitive closure of the triples

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

10. def computeTransitiveClosureOpt(triples: DataSet[Triple]): DataSet[Triple]

    

    Computes the transitive closure on a DataSet of triples.

    Computes the transitive closure on a DataSet of triples. Note, that the assumption is that all triples do have the same predicate. This implementation uses the Flink iterate operator (see https://ci.apache.org/projects/flink/flink-docs-master/dev/batch/iterations.html")

    triples

    the DataSet of triples

    returns

    a DataSet containing the transitive closure of the triples

11. def computeTransitiveClosureOptSemiNaive(triples: DataSet[Triple], predicate: Node = null): DataSet[Triple]

    

    Computes the transitive closure on a DataSet of triples.

    Computes the transitive closure on a DataSet of triples. Note, that the assumption is that all triples do have the same predicate. If no predicate is given, we take any triple from the dataset and use its predicate. We highly recommend to provide the predicate in order to avoid unnecessary operations.

    This implementation uses the Flink iterate operator (see https://ci.apache.org/projects/flink/flink-docs-master/dev/batch/iterations.html")

    triples

    the DataSet of triples

    predicate

    the optional predicate

    returns

    a DataSet containing the transitive closure of the triples

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    AnyRef

16. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

20. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

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

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

    

    Definition Classes

    AnyRef → Any

22. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

26. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

27. def log: Logger

    

    Attributes

    protected

    Definition Classes

    Logging

28. def logName: String

    

    Attributes

    protected

    Definition Classes

    Logging

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

    

    Definition Classes

    AnyRef

30. val nodeKeyFct: (Node) ⇒ Int

    

31. final def notify(): Unit

    

    Definition Classes

    AnyRef

32. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

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

    

    Definition Classes

    Profiler

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

    

    Definition Classes

    AnyRef

35. def toString(): String

    

    Definition Classes

    AnyRef → Any

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

39. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging