com.bigdata.rdf.rio
Class BasicRioLoader

java.lang.Object
  com.bigdata.rdf.rio.BasicRioLoader

All Implemented Interfaces:

IRioLoader

Direct Known Subclasses:

PresortRioLoader

public class BasicRioLoader
extends Object
implements IRioLoader

Parses data but does not load it into the indices.

Version:

$Id: BasicRioLoader.java 2265 2009-10-26 12:51:06Z thompsonbry $

Author:

Bryan Thompson

Field Summary

Fields inherited from interface com.bigdata.rdf.rio.IRioLoader

DEBUG, INFO, log

Constructor Summary

BasicRioLoader(BigdataValueFactory valueFactory)

Method Summary

void	addRioLoaderListener(RioLoaderListener l) Register a listener.
protected void	before() Invoked before parse (default is NOP).
protected void	cleanUp() Invoked from finally clause after parse regardless of success or failure.
protected void	error(Exception ex) Invoked if the parse fails (default is NOP).
long	getInsertRate()
long	getInsertTime()
protected RDFParser	getParser(RDFFormat rdfFormat) Choose the parser based on the RDFFormat specified to the constructor.
long	getStatementsAdded()
void	loadRdf(InputStream is, String baseURI, RDFFormat rdfFormat, boolean verifyData) Parse RDF data.
void	loadRdf(Reader reader, String baseURI, RDFFormat rdfFormat, boolean verifyData) Parse RDF data.
protected void	loadRdf2(Object source, String baseURI, RDFFormat rdfFormat, boolean verifyData) Core implementation.
RDFHandler	newRDFHandler() Note: YOU MUST override this method to install a different RDFHandler.
protected void	notifyListeners()
void	removeRioLoaderListener(RioLoaderListener l) Remove a listener.
protected void	success() Invoked after successful parse (default is NOP).

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BasicRioLoader

public BasicRioLoader(BigdataValueFactory valueFactory)

Method Detail

getStatementsAdded

public final long getStatementsAdded()

Specified by:

getStatementsAdded in interface IRioLoader

getInsertTime

public final long getInsertTime()

Specified by:

getInsertTime in interface IRioLoader

getInsertRate

public final long getInsertRate()

Specified by:

getInsertRate in interface IRioLoader

addRioLoaderListener

public final void addRioLoaderListener(RioLoaderListener l)

Description copied from interface: IRioLoader

Register a listener.

Specified by:

addRioLoaderListener in interface IRioLoader

Parameters:

l - The listener.

removeRioLoaderListener

public final void removeRioLoaderListener(RioLoaderListener l)

Description copied from interface: IRioLoader

Remove a listener.

Specified by:

removeRioLoaderListener in interface IRioLoader

Parameters:

l - The listener.

notifyListeners

protected final void notifyListeners()

getParser

protected final RDFParser getParser(RDFFormat rdfFormat)

Choose the parser based on the RDFFormat specified to the constructor.

Returns:

The parser.

TODO:

reuse parser instances for the same RDFFormat?

loadRdf

public final void loadRdf(InputStream is,
                          String baseURI,
                          RDFFormat rdfFormat,
                          boolean verifyData)
                   throws Exception

Description copied from interface: IRioLoader

Parse RDF data.

Specified by:

loadRdf in interface IRioLoader

Parameters:

is - The source from which the data will be read.

rdfFormat - The interchange format.

verifyData - Verification is enabled when true.

Throws:

Exception

loadRdf

public final void loadRdf(Reader reader,
                          String baseURI,
                          RDFFormat rdfFormat,
                          boolean verifyData)
                   throws Exception

Description copied from interface: IRioLoader

Parse RDF data.

Specified by:

loadRdf in interface IRioLoader

Parameters:

reader - The source from which the data will be read.

baseURI - The base URL for those data.

rdfFormat - The interchange format.

verifyData - Verification is enabled when true.

Throws:

Exception

loadRdf2

protected void loadRdf2(Object source,
                        String baseURI,
                        RDFFormat rdfFormat,
                        boolean verifyData)
                 throws Exception

Core implementation.

Parameters:

source - A Reader or InputStream.

baseURI -

rdfFormat -

verifyData -

Throws:

Exception

before

protected void before()

Invoked before parse (default is NOP).

success

protected void success()

Invoked after successful parse (default is NOP).

error

protected void error(Exception ex)

Invoked if the parse fails (default is NOP).

cleanUp

protected void cleanUp()

Invoked from finally clause after parse regardless of success or failure.

newRDFHandler

public RDFHandler newRDFHandler()

Note: YOU MUST override this method to install a different RDFHandler. The default is the BasicRDFHandler which does NOTHING.