Class/Object

net.sansa_stack.rdf.spark.model

TripleRDD

Related Docs: object TripleRDD | package model

Permalink

class TripleRDD extends Serializable with JenaSparkRDDOps

Implicit wrapper for functions for RDD of Jena Triples.

Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. TripleRDD
  2. JenaSparkRDDOps
  3. JenaNodeOps
  4. DefaultURIOps
  5. RDFNodeOps
  6. SparkRDDGraphOps
  7. RDFGraphOps
  8. RDFDSL
  9. URIOps
  10. Serializable
  11. Serializable
  12. AnyRef
  13. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new TripleRDD(graphRDD: RDD[Triple])

    Permalink

Value Members

  1. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  4. def ANY: Node_ANY

    Permalink
    Definition Classes
    JenaNodeOpsRDFNodeOps
  5. object BNode

    Permalink
    Definition Classes
    RDFDSL
  6. object Graph

    Permalink
    Definition Classes
    RDFDSL
  7. object Lang

    Permalink
    Definition Classes
    RDFDSL
  8. object Literal

    Permalink
    Definition Classes
    RDFDSL
  9. object Triple

    Permalink
    Definition Classes
    RDFDSL
  10. object URI

    Permalink
    Definition Classes
    RDFDSL
  11. def __rdfLangStringURI: Node_URI

    Permalink
    Definition Classes
    JenaNodeOps
  12. def __xsdString: RDFDatatype

    Permalink
    Definition Classes
    JenaNodeOps
  13. def __xsdStringURI: Node_URI

    Permalink
    Definition Classes
    JenaNodeOps
  14. def appendSegment(uri: JenaSparkRDD.URI, segment: String): JenaSparkRDD.URI

    Permalink

    Definition Classes
    DefaultURIOpsURIOps
  15. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  16. def bnode(s: String): JenaSparkRDD.BNode

    Permalink
    Definition Classes
    RDFDSL
  17. def bnode(): JenaSparkRDD.BNode

    Permalink
    Definition Classes
    RDFDSL
  18. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  19. def difference(g1: RDD[JenaSparkRDD.Triple], g2: RDD[JenaSparkRDD.Triple]): RDD[JenaSparkRDD.Triple]

    Permalink
    Definition Classes
    SparkRDDGraphOpsRDFGraphOps
  20. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  21. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  22. def filterObjects(func: (Node) ⇒ Boolean): RDD[Triple]

    Permalink
  23. def filterPredicates(func: (Node_URI) ⇒ Boolean): RDD[Triple]

    Permalink
  24. def filterSubjects(func: (Node) ⇒ Boolean): RDD[Triple]

    Permalink
  25. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  26. def find(subject: Node, predicate: Node, objectt: Node): RDD[Triple]

    Permalink
  27. def find(graph: RDD[JenaSparkRDD.Triple], subject: JenaSparkRDD.NodeMatch, predicate: JenaSparkRDD.NodeMatch, objectt: JenaSparkRDD.NodeMatch): Iterator[JenaSparkRDD.Triple]

    Permalink
    Definition Classes
    SparkRDDGraphOpsRDFGraphOps
  28. def findGraph(graph: RDD[JenaSparkRDD.Triple], subject: JenaSparkRDD.NodeMatch, predicate: JenaSparkRDD.NodeMatch, objectt: JenaSparkRDD.NodeMatch): RDD[JenaSparkRDD.Triple]

    Permalink
    Definition Classes
    SparkRDDGraphOpsRDFGraphOps
  29. def foldNode[T](node: Node)(funURI: (Node_URI) ⇒ T, funBNode: (Node_Blank) ⇒ T, funLiteral: (Node_Literal) ⇒ T): T

    Permalink
    Definition Classes
    JenaNodeOpsRDFNodeOps
  30. def foldNodeMatch[T](nodeMatch: Node)(funANY: ⇒ T, funConcrete: (Node) ⇒ T): T

    Permalink
    Definition Classes
    JenaNodeOpsRDFNodeOps
  31. def fromBNode(bn: Node_Blank): String

    Permalink
    Definition Classes
    JenaNodeOpsRDFNodeOps
  32. def fromLang(lang: String): String

    Permalink
    Definition Classes
    JenaNodeOpsRDFNodeOps
  33. def fromLiteral(literal: Node_Literal): (String, Node_URI, Option[String])

    Permalink
    Definition Classes
    JenaNodeOpsRDFNodeOps
  34. def fromNTriples(rdf: String, baseIRI: String): Iterable[Triple]

    Permalink
    Definition Classes
    JenaNodeOpsRDFNodeOps
  35. def fromTriple(t: Triple): (Node, Node_URI, Node)

    Permalink
    Definition Classes
    JenaNodeOpsRDFNodeOps
  36. def fromUri(node: Node_URI): String

    Permalink
    Definition Classes
    JenaNodeOpsRDFNodeOps
  37. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any
  38. def getFragment(uri: JenaSparkRDD.URI): Option[String]

    Permalink

    returns the fragment part of uri

    returns the fragment part of uri

    Definition Classes
    DefaultURIOpsURIOps
  39. def getObjects: RDD[Node]

    Permalink
  40. def getObjects(graph: JenaSparkRDD.Graph, subject: JenaSparkRDD.Node, predicate: JenaSparkRDD.URI): Iterable[JenaSparkRDD.Node]

    Permalink
    Definition Classes
    RDFGraphOps
  41. def getObjectsRDD(graph: RDD[JenaSparkRDD.Triple], predicate: JenaSparkRDD.URI): RDD[JenaSparkRDD.Node]

    Permalink
    Definition Classes
    SparkRDDGraphOps
  42. def getObjectsRDD(graph: RDD[JenaSparkRDD.Triple], subject: JenaSparkRDD.Node, predicate: JenaSparkRDD.URI): RDD[JenaSparkRDD.Node]

    Permalink
    Definition Classes
    SparkRDDGraphOps
  43. def getObjectsWithPredicate(subject: Node, predicate: Node_URI): RDD[Node]

    Permalink
  44. def getObjectsWithPredicate(predicate: Node_URI): RDD[Node]

    Permalink
  45. def getPredicates: RDD[Node]

    Permalink
  46. def getPredicates(graph: JenaSparkRDD.Graph, subject: JenaSparkRDD.Node): Iterable[JenaSparkRDD.URI]

    Permalink
    Definition Classes
    RDFGraphOps
  47. def getPredicatesRDD(graph: RDD[JenaSparkRDD.Triple], subject: JenaSparkRDD.Node): RDD[JenaSparkRDD.URI]

    Permalink
    Definition Classes
    SparkRDDGraphOps
  48. def getString(uri: JenaSparkRDD.URI): String

    Permalink
    Definition Classes
    DefaultURIOpsURIOps
  49. def getSubjects: RDD[Node]

    Permalink
  50. def getSubjects(graph: JenaSparkRDD.Graph, predicate: JenaSparkRDD.URI, obj: JenaSparkRDD.Node): Iterable[JenaSparkRDD.Node]

    Permalink
    Definition Classes
    RDFGraphOps
  51. def getSubjectsRDD(graph: RDD[JenaSparkRDD.Triple], predicate: JenaSparkRDD.URI): RDD[JenaSparkRDD.Node]

    Permalink
    Definition Classes
    SparkRDDGraphOps
  52. def getSubjectsRDD(graph: RDD[JenaSparkRDD.Triple], predicate: JenaSparkRDD.URI, obj: JenaSparkRDD.Node): RDD[JenaSparkRDD.Node]

    Permalink
    Definition Classes
    SparkRDDGraphOps
  53. def getSubjectsWithPredicate(predicate: Node_URI, objectt: Node): RDD[Node]

    Permalink
  54. def getSubjectsWithPredicate(predicate: Node_URI): RDD[Node]

    Permalink
  55. def getTriples: Iterable[Triple]

    Permalink
  56. def getTriples(graph: RDD[JenaSparkRDD.Triple]): Iterable[JenaSparkRDD.Triple]

    Permalink
    Definition Classes
    SparkRDDGraphOpsRDFGraphOps
  57. def graphSize(g: RDD[JenaSparkRDD.Triple]): Long

    Permalink
    Definition Classes
    SparkRDDGraphOpsRDFGraphOps
  58. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  59. def intersection(graphs: Seq[RDD[JenaSparkRDD.Triple]]): RDD[JenaSparkRDD.Triple]

    Permalink
    Definition Classes
    SparkRDDGraphOpsRDFGraphOps
  60. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  61. def isPureFragment(uri: JenaSparkRDD.URI): Boolean

    Permalink

    Definition Classes
    DefaultURIOpsURIOps
  62. def isomorphism(left: RDD[JenaSparkRDD.Triple], right: RDD[JenaSparkRDD.Triple]): Boolean

    Permalink

    Implement Spark algorithm for determining whether left and right are isomorphic

    Implement Spark algorithm for determining whether left and right are isomorphic

    Definition Classes
    SparkRDDGraphOpsRDFGraphOps
  63. def jenaDatatype(datatype: Node_URI): RDFDatatype

    Permalink
    Definition Classes
    JenaNodeOps
  64. def lastSegment(uri: JenaSparkRDD.URI): String

    Permalink

    Definition Classes
    DefaultURIOpsURIOps
  65. def loadGraphFromNTriples(file: String, baseIRI: String): RDD[JenaSparkRDD.Triple]

    Permalink
    Definition Classes
    SparkRDDGraphOpsRDFGraphOps
  66. def loadGraphFromSequenceFile(file: String): RDD[JenaSparkRDD.Triple]

    Permalink
    Definition Classes
    SparkRDDGraphOpsRDFGraphOps
  67. def makeBNode(): Node_Blank

    Permalink
    Definition Classes
    JenaNodeOpsRDFNodeOps
  68. def makeBNodeLabel(label: String): Node_Blank

    Permalink
    Definition Classes
    JenaNodeOpsRDFNodeOps
  69. def makeGraph(triples: Iterable[JenaSparkRDD.Triple]): RDD[JenaSparkRDD.Triple]

    Permalink
    Definition Classes
    SparkRDDGraphOpsRDFGraphOps
  70. def makeLang(langString: String): String

    Permalink
    Definition Classes
    JenaNodeOpsRDFNodeOps
  71. def makeLangTaggedLiteral(lexicalForm: String, lang: String): Node_Literal

    Permalink
    Definition Classes
    JenaNodeOpsRDFNodeOps
  72. def makeLiteral(lexicalForm: String, datatype: Node_URI): Node_Literal

    Permalink
    Definition Classes
    JenaNodeOpsRDFNodeOps
  73. def makeTriple(s: Node, p: Node_URI, o: Node): Triple

    Permalink
    Definition Classes
    JenaNodeOpsRDFNodeOps
  74. def makeUri(iriStr: String): Node_URI

    Permalink
    Definition Classes
    JenaNodeOpsRDFNodeOps
  75. def mapLiterals(func: (Node_Literal) ⇒ Node_Literal): RDD[Triple]

    Permalink
  76. def mapObjects(func: (Node) ⇒ Node): RDD[Triple]

    Permalink
  77. def mapPredicates(func: (Node_URI) ⇒ Node_URI): RDD[Triple]

    Permalink
  78. def mapSubjects(func: (Node) ⇒ Node): RDD[Triple]

    Permalink
  79. def mapURIs(func: (Node_URI) ⇒ Node_URI): RDD[Triple]

    Permalink
  80. final def matchNode[T <: JenaSparkRDD](node: RDFNodeOps.matchNode.T.Node, nodeMatch: RDFNodeOps.matchNode.T.NodeMatch): Boolean

    Permalink
    Definition Classes
    RDFNodeOps
  81. def matches(node1: Node, node2: Node): Boolean

    Permalink
    Definition Classes
    JenaNodeOpsRDFNodeOps
  82. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  83. implicit def nodeTag: ClassTag[JenaSparkRDD.Node]

    Permalink
    Attributes
    protected
    Definition Classes
    JenaSparkRDDOpsRDFGraphOps
  84. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
  85. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
  86. def relativize(uri: JenaSparkRDD.URI, other: JenaSparkRDD.URI): JenaSparkRDD.URI

    Permalink

    Definition Classes
    DefaultURIOpsURIOps
  87. def resolve(uri: JenaSparkRDD.URI, against: JenaSparkRDD.URI): JenaSparkRDD.URI

    Permalink

    Definition Classes
    DefaultURIOpsURIOps
  88. def saveGraphToNTriples(file: String): Unit

    Permalink
  89. def saveGraphToNTriples(graph: RDD[JenaSparkRDD.Triple], file: String): Unit

    Permalink
    Definition Classes
    SparkRDDGraphOpsRDFGraphOps
  90. def saveGraphToSequenceFile(file: String): Unit

    Permalink
  91. def saveGraphToSequenceFile(graph: RDD[JenaSparkRDD.Triple], file: String): Unit

    Permalink
    Definition Classes
    SparkRDDGraphOpsRDFGraphOps
  92. def sparkContext: SparkContext

    Permalink
    Definition Classes
    TripleRDDSparkRDDGraphOps
    Annotations
    @transient()
  93. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef
  94. implicit def toConcreteNodeMatch(node: Node): Node

    Permalink
    Definition Classes
    JenaNodeOpsRDFNodeOps
  95. def toNTriples(triples: Iterable[Triple]): String

    Permalink
    Definition Classes
    JenaNodeOpsRDFNodeOps
  96. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any
  97. implicit def tripleTag: ClassTag[JenaSparkRDD.URI]

    Permalink
    Attributes
    protected
    Definition Classes
    JenaSparkRDDOpsRDFGraphOps
  98. def union(graphs: Seq[RDD[JenaSparkRDD.Triple]]): RDD[JenaSparkRDD.Triple]

    Permalink
    Definition Classes
    SparkRDDGraphOpsRDFGraphOps
  99. implicit def uriTag: ClassTag[JenaSparkRDD.Triple]

    Permalink
    Attributes
    protected
    Definition Classes
    JenaSparkRDDOpsRDFGraphOps
  100. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  101. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  102. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  103. def withFragment(uri: JenaSparkRDD.URI, frag: String): JenaSparkRDD.URI

    Permalink

    returns uri with frag as its fragment part, newly added or replaced

    returns uri with frag as its fragment part, newly added or replaced

    Definition Classes
    DefaultURIOpsURIOps
  104. def withoutFragment(uri: JenaSparkRDD.URI): JenaSparkRDD.URI

    Permalink

    returns uri without its fragment part if it had one

    returns uri without its fragment part if it had one

    Definition Classes
    DefaultURIOpsURIOps

Inherited from JenaSparkRDDOps

Inherited from JenaNodeOps[JenaSparkRDD]

Inherited from DefaultURIOps[JenaSparkRDD]

Inherited from RDFNodeOps[JenaSparkRDD]

Inherited from SparkRDDGraphOps[JenaSparkRDD]

Inherited from RDFGraphOps[JenaSparkRDD]

Inherited from RDFDSL[JenaSparkRDD]

Inherited from URIOps[JenaSparkRDD]

Inherited from Serializable

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped