Package

net.sansa_stack.rdf.spark

io

Permalink

package io

Wrap up implicit classes/methods to read/write RDF data from N-Triples or Turtle files into either DataFrame or RDD.

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. io
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. class CustomErrorHandler extends ErrorHandler

    Permalink

    A custom error handler that doesn't throw an exception on fatal parse errors.

    A custom error handler that doesn't throw an exception on fatal parse errors. This allows for simply skipping those triples instead of aborting the whole parse process.

  2. class JenaKryoRegistrator extends KryoRegistrator

    Permalink

    Created by nilesh on 01/06/2016.

  3. implicit class RDFDataFrameReader extends Logging

    Permalink

    Adds methods, rdf, ntriples and turtle, to DataFrameReader that allows to read N-Triples and Turtle files.

  4. implicit class RDFDataFrameWriter[T] extends AnyRef

    Permalink

    Adds methods, ntriples and turtle, to DataFrameWriter that allows to write N-Triples files.

  5. implicit class RDFReader extends AnyRef

    Permalink

    Adds methods, rdf(lang: Lang), ntriples, nquads, and turtle, to SparkSession that allows to read N-Triples, N-Quads and Turtle files.

  6. class RDFSparseTensorReader extends AnyRef

    Permalink

    Created by nilesh Build an RDD of (s,p,o) coordinates, with integer IDs starting from 0 for representing URIs Needed for training ML models on knowledge graphs TODO docs

  7. implicit class RDFWriter[T] extends AnyRef

    Permalink

    Adds methods, ntriples and turtle, to org.apache.spark.SparkContext that allows to write N-Triples and Turtle files.

Value Members

  1. object ErrorParseMode extends Enumeration

    Permalink
  2. object NTripleReader

    Permalink

    An N-Triples reader.

    An N-Triples reader. One triple per line is assumed.

  3. object RDFLang extends Enumeration

    Permalink
  4. object WarningParseMode extends Enumeration

    Permalink
  5. package benchmark

    Permalink
  6. package index

    Permalink
  7. package nquads

    Permalink
  8. package ntriples

    Permalink
  9. package rdfxml

    Permalink
  10. package stream

    Permalink
  11. def toRow(nodes: Seq[Node]): Row

    Permalink

    Converts a list Jena Node objects to a Spark SQL Row.

    Converts a list Jena Node objects to a Spark SQL Row.

    nodes

    the nodes

    returns

    the row

  12. def toRow(triple: Triple): Row

    Permalink

    Converts a Jena Triple to a Spark SQL Row with three columns.

    Converts a Jena Triple to a Spark SQL Row with three columns.

    triple

    the triple

    returns

    the row

  13. package turtle

    Permalink

Inherited from AnyRef

Inherited from Any

Ungrouped