TripleOperations

Instance Constructors

new TripleOperations(triples: RDD[Triple])

Value Members

final def !=(arg0: Any): Boolean

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

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

Definition Classes
AnyRef → Any
def add(triple: Triple): RDD[Triple]

Add a statement to the current RDF graph.
Add a statement to the current RDF graph.
triple
the triple to be added.
returns
new RDD of triples containing this statement.

See also
net.sansa_stack.rdf.spark.model.rdd.TripleOps.add
def addAll(triple: Seq[Triple]): RDD[Triple]

Add a list of statements to the current RDF graph.
Add a list of statements to the current RDF graph.
triple
the list of triples to be added.
returns
new RDD of triples containing this list of statements.

See also
net.sansa_stack.rdf.spark.model.rdd.TripleOps.addAll
final def asInstanceOf[T0]: T0

Definition Classes
Any
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
def contains(triple: Triple): Boolean

Determine if a triple is present in this RDF graph.
Determine if a triple is present in this RDF graph.
triple
the triple to be checked
returns
true if the statement s is in this RDF graph, false otherwise
def contains(subject: Some[Node], predicate: Some[Node], object: Some[Node]): Boolean

Determine whether this RDF graph contains any triples with a given (subject, predicate, object) pattern.
Determine whether this RDF graph contains any triples with a given (subject, predicate, object) pattern.
subject
the subject (None for any)
predicate
the predicate (None for any)
object
the object (None for any)
returns
true if there exists within this RDF graph a triple with (S, P, O) pattern, false otherwise
def contains(subject: Some[Node], predicate: Some[Node]): Boolean

Determine whether this RDF graph contains any triples with a given subject and predicate.
Determine whether this RDF graph contains any triples with a given subject and predicate.
subject
the subject (None for any)
predicate
the predicate (Node for any)
returns
true if there exists within this RDF graph a triple with subject and predicate, false otherwise
def containsAll(other: RDD[Triple]): Boolean

Determine if all of the statements in an RDF graph are also contained in this RDF graph.
Determine if all of the statements in an RDF graph are also contained in this RDF graph.
other
the other RDF graph containing the statements to be tested
returns
true if all of the statements in RDF graph are also contained in this RDF graph and false otherwise.
def containsAny(other: RDD[Triple]): Boolean

Determine if any of the triples in an RDF graph are also contained in this RDF graph.
Determine if any of the triples in an RDF graph are also contained in this RDF graph.
other
the other RDF graph containing the statements to be tested
returns
true if any of the statements in RDF graph are also contained in this RDF graph and false otherwise.
def difference(other: RDD[Triple]): RDD[Triple]

Returns a new RDF graph that contains the difference between the current RDF graph and the given RDF graph.
Returns a new RDF graph that contains the difference between the current RDF graph and the given RDF graph.
other
of the other RDF graph
returns
the difference of both RDF graphs

See also
net.sansa_stack.rdf.spark.model.rdd.TripleOps.difference
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

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

Filter out the objects from a given RDD[Triple], based on a specific function @func .
Filter out the objects from a given RDD[Triple], based on a specific function @func .
func
a partial funtion.
returns
RDD[Triple] a subset of the given RDD.

See also
net.sansa_stack.rdf.spark.model.rdd.TripleOps.filterObjects
def filterPredicates(func: (Node) ⇒ Boolean): RDD[Triple]

Filter out the predicates from a given RDD[Triple], based on a specific function @func .
Filter out the predicates from a given RDD[Triple], based on a specific function @func .
func
a partial funtion.
returns
RDD[Triple] a subset of the given RDD.

See also
net.sansa_stack.rdf.spark.model.rdd.TripleOps.filterPredicates
def filterSubjects(func: (Node) ⇒ Boolean): RDD[Triple]

Filter out the subject from a given RDD[Triple], based on a specific function @func .
Filter out the subject from a given RDD[Triple], based on a specific function @func .
func
a partial funtion.
returns
RDD[Triple] a subset of the given RDD.

See also
net.sansa_stack.rdf.spark.model.rdd.TripleOps.filterSubjects
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
def find(triple: Triple): RDD[Triple]

Returns an RDD of triples that match with the given input.
Returns an RDD of triples that match with the given input.
triple
the triple to be checked
returns
RDD of triples that match the given input

See also
net.sansa_stack.rdf.spark.model.rdd.TripleOps.find
def find(subject: Option[Node] = None, predicate: Option[Node] = None, object: Option[Node] = None): RDD[Triple]

Returns an RDD of triples that match with the given input.
Returns an RDD of triples that match with the given input.
subject
the subject
predicate
the predicate
object
the object
returns
RDD of triples

See also
net.sansa_stack.rdf.spark.model.rdd.TripleOps.find
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
def getObjects(): RDD[Node]

Get objects.
Get objects.
returns
RDD[Node] which contains list of the objects.

See also
net.sansa_stack.rdf.spark.model.rdd.TripleOps.getObjects
def getPredicates(): RDD[Node]

Get predicates.
Get predicates.
returns
RDD[Node] which contains list of the predicates.

See also
net.sansa_stack.rdf.spark.model.rdd.TripleOps.getPredicates
def getSubjects(): RDD[Node]

Get subjects.
Get subjects.
returns
RDD[Node] which contains list of the subjects.

See also
net.sansa_stack.rdf.spark.model.rdd.TripleOps.getSubjects
def getTriples(): RDD[Triple]

Get triples.
Get triples.
returns
RDD[Triple] which contains list of the triples.
def hashCode(): Int

Definition Classes
AnyRef → Any
def intersection(other: RDD[Triple]): RDD[Triple]

Returns a new RDF graph that contains the intersection of the current RDF graph with the given RDF graph.
Returns a new RDF graph that contains the intersection of the current RDF graph with the given RDF graph.
other
of the other RDF graph
returns
the intersection of both RDF graphs

See also
net.sansa_stack.rdf.spark.model.rdd.TripleOps.intersection
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
def isTraceEnabled(): Boolean

Attributes
protected
Definition Classes
Logging
def log: Logger

Attributes
protected
Definition Classes
Logging
def logDebug(msg: ⇒ String, throwable: Throwable): Unit

Attributes
protected
Definition Classes
Logging
def logDebug(msg: ⇒ String): Unit

Attributes
protected
Definition Classes
Logging
def logError(msg: ⇒ String, throwable: Throwable): Unit

Attributes
protected
Definition Classes
Logging
def logError(msg: ⇒ String): Unit

Attributes
protected
Definition Classes
Logging
def logInfo(msg: ⇒ String, throwable: Throwable): Unit

Attributes
protected
Definition Classes
Logging
def logInfo(msg: ⇒ String): Unit

Attributes
protected
Definition Classes
Logging
def logName: String

Attributes
protected
Definition Classes
Logging
def logTrace(msg: ⇒ String, throwable: Throwable): Unit

Attributes
protected
Definition Classes
Logging
def logTrace(msg: ⇒ String): Unit

Attributes
protected
Definition Classes
Logging
def logWarning(msg: ⇒ String, throwable: Throwable): Unit

Attributes
protected
Definition Classes
Logging
def logWarning(msg: ⇒ String): Unit

Attributes
protected
Definition Classes
Logging
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
def remove(triple: Triple): RDD[Triple]

Removes a statement from the current RDF graph.
Removes a statement from the current RDF graph. The statement with the same subject, predicate and object as that supplied will be removed from the model.
triple
the statement to be removed.
returns
new RDD of triples without this statement.

See also
net.sansa_stack.rdf.spark.model.rdd.TripleOps.remove
def removeAll(triple: Seq[Triple]): RDD[Triple]

Removes all the statements from the current RDF graph.
Removes all the statements from the current RDF graph. The statements with the same subject, predicate and object as those supplied will be removed from the model.
triple
the list of statements to be removed.
returns
new RDD of triples without these statements.

See also
net.sansa_stack.rdf.spark.model.rdd.TripleOps.removeAll
def saveAsNTriplesFile(path: String): Unit

Write N-Triples from a given RDD of triples
Write N-Triples from a given RDD of triples
path
path to the file containing N-Triples

See also
net.sansa_stack.rdf.spark.model.rdd.TripleOps.saveAsNTriplesFile
def size(): Long

Return the number of triples.
Return the number of triples.
returns
the number of triples

See also
net.sansa_stack.rdf.spark.model.rdd.TripleOps.size
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def toDF(): DataFrame

Convert a RDD[Triple] into a DataFrame.
Convert a RDD[Triple] into a DataFrame.
returns
a DataFrame of triples.

See also
net.sansa_stack.rdf.spark.model.rdd.TripleOps.toDF
def toDS(): Dataset[Triple]

Convert an RDD of Triple into a Dataset of Triple.
Convert an RDD of Triple into a Dataset of Triple.
returns
a Dataset of triples.

See also
net.sansa_stack.rdf.spark.model.rdd.TripleOps.toDS
def toString(): String

Definition Classes
AnyRef → Any
def union(other: RDD[Triple]): RDD[Triple]

Return the union of this RDF graph and another one.
Return the union of this RDF graph and another one.
other
of the other RDF graph
returns
graph (union of both)

See also
net.sansa_stack.rdf.spark.model.rdd.TripleOps.union
def unionAll(others: Seq[RDD[Triple]]): RDD[Triple]

Return the union all of RDF graphs.
Return the union all of RDF graphs.
returns
graph (union of all)

See also
net.sansa_stack.rdf.spark.model.rdd.TripleOps.unionAll
final def wait(): Unit

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

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

Definition Classes
AnyRef
Annotations
@throws( ... )

Related Doc: package model

implicit class TripleOperations extends Logging

Instance Constructors

new TripleOperations(triples: RDD[Triple])

Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

def add(triple: Triple): RDD[Triple]

def addAll(triple: Seq[Triple]): RDD[Triple]

final def asInstanceOf[T0]: T0

def clone(): AnyRef

def contains(triple: Triple): Boolean

def contains(subject: Some[Node], predicate: Some[Node], object: Some[Node]): Boolean

def contains(subject: Some[Node], predicate: Some[Node]): Boolean

def containsAll(other: RDD[Triple]): Boolean

def containsAny(other: RDD[Triple]): Boolean

def difference(other: RDD[Triple]): RDD[Triple]

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def filterObjects(func: (Node) ⇒ Boolean): RDD[Triple]

def filterPredicates(func: (Node) ⇒ Boolean): RDD[Triple]

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

def finalize(): Unit

def find(triple: Triple): RDD[Triple]

def find(subject: Option[Node] = None, predicate: Option[Node] = None, object: Option[Node] = None): RDD[Triple]

final def getClass(): Class[_]

def getObjects(): RDD[Node]

def getPredicates(): RDD[Node]

def getSubjects(): RDD[Node]

def getTriples(): RDD[Triple]

def hashCode(): Int

def intersection(other: RDD[Triple]): RDD[Triple]

final def isInstanceOf[T0]: Boolean

def isTraceEnabled(): Boolean

def log: Logger

def logDebug(msg: ⇒ String, throwable: Throwable): Unit

def logDebug(msg: ⇒ String): Unit

def logError(msg: ⇒ String, throwable: Throwable): Unit

def logError(msg: ⇒ String): Unit

def logInfo(msg: ⇒ String, throwable: Throwable): Unit

def logInfo(msg: ⇒ String): Unit

def logName: String

def logTrace(msg: ⇒ String, throwable: Throwable): Unit

def logTrace(msg: ⇒ String): Unit

def logWarning(msg: ⇒ String, throwable: Throwable): Unit

def logWarning(msg: ⇒ String): Unit

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

def remove(triple: Triple): RDD[Triple]

def removeAll(triple: Seq[Triple]): RDD[Triple]

def saveAsNTriplesFile(path: String): Unit

def size(): Long

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

def toDF(): DataFrame

def toDS(): Dataset[Triple]

def toString(): String

def union(other: RDD[Triple]): RDD[Triple]

def unionAll(others: Seq[RDD[Triple]]): RDD[Triple]

final def wait(): Unit

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

final def wait(arg0: Long): Unit

Inherited from Logging

Inherited from AnyRef

Inherited from Any

Ungrouped