com.bigdata.rdf.rio

Class PresortRioLoader

java.lang.Object

com.bigdata.rdf.rio.BasicRioLoader

com.bigdata.rdf.rio.PresortRioLoader

All Implemented Interfaces:

IRioLoader, org.openrdf.rio.RDFHandler

public class PresortRioLoader
extends BasicRioLoader
implements org.openrdf.rio.RDFHandler

Statement handler for the RIO RDF Parser that writes on a StatementBuffer.

Author:

Bryan Thompson

Field Summary

Fields

Modifier and Type	Field and Description
protected IStatementBuffer<?>	buffer Used to buffer RDF Values and Statements emitted by the RDF parser (the value is supplied by the ctor).

Fields inherited from class com.bigdata.rdf.rio.BasicRioLoader

defaultGraph, log, stmtsAdded

Constructor Summary

Constructors

Constructor and Description
PresortRioLoader(IStatementBuffer<?> buffer) Sets up parser to load RDF.
PresortRioLoader(IStatementBuffer<?> buffer, boolean flush)

Method Summary

Methods

Modifier and Type	Method and Description
void	endRDF()
protected void	error(Exception ex) Invoked if the parse fails (default is NOP).
void	handleComment(String arg0)
void	handleNamespace(String arg0, String arg1)
void	handleStatement(org.openrdf.model.Statement stmt)
org.openrdf.rio.RDFHandler	newRDFHandler() Note: YOU MUST override this method to install a different RDFHandler.
void	startRDF()
protected void	success() Invoked after successful parse (default is NOP).

Methods inherited from class com.bigdata.rdf.rio.BasicRioLoader

addRioLoaderListener, before, cleanUp, getInsertRate, getInsertTime, getParser, getStatementsAdded, loadRdf, loadRdf, loadRdf2, notifyListeners, removeRioLoaderListener

Methods inherited from class java.lang.Object

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

Field Detail

buffer

protected final IStatementBuffer<?> buffer

Used to buffer RDF Values and Statements emitted by the RDF parser (the value is supplied by the ctor).

Constructor Detail

PresortRioLoader

public PresortRioLoader(IStatementBuffer<?> buffer)

Sets up parser to load RDF.

Parameters:

buffer - The buffer used to collect, sort, and write statements onto the database.

PresortRioLoader

public PresortRioLoader(IStatementBuffer<?> buffer,
                boolean flush)

Parameters:

buffer - The buffer onto which the parsed statements will be written.

flush - When true, the buffer will be flushed when the end of the input is reached.

See Also:

(DataLoader.Options.FLUSH does not defer flush of StatementBuffer)

Method Detail

success

protected void success()

Invoked after successful parse (default is NOP).

bulk insert the buffered data into the store iff flush:=true

Overrides:

success in class BasicRioLoader

error

protected void error(Exception ex)

Description copied from class: BasicRioLoader

Invoked if the parse fails (default is NOP).

Overrides:

error in class BasicRioLoader

newRDFHandler

public org.openrdf.rio.RDFHandler newRDFHandler()

Description copied from class: BasicRioLoader

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

Overrides:

newRDFHandler in class BasicRioLoader

handleStatement

public void handleStatement(org.openrdf.model.Statement stmt)

Specified by:

handleStatement in interface org.openrdf.rio.RDFHandler

endRDF

public void endRDF()
            throws org.openrdf.rio.RDFHandlerException

Specified by:

endRDF in interface org.openrdf.rio.RDFHandler

Throws:

org.openrdf.rio.RDFHandlerException

handleComment

public void handleComment(String arg0)
                   throws org.openrdf.rio.RDFHandlerException

Specified by:

handleComment in interface org.openrdf.rio.RDFHandler

Throws:

org.openrdf.rio.RDFHandlerException

handleNamespace

public void handleNamespace(String arg0,
                   String arg1)
                     throws org.openrdf.rio.RDFHandlerException

Specified by:

handleNamespace in interface org.openrdf.rio.RDFHandler

Throws:

org.openrdf.rio.RDFHandlerException

startRDF

public void startRDF()
              throws org.openrdf.rio.RDFHandlerException

Specified by:

startRDF in interface org.openrdf.rio.RDFHandler

Throws:

org.openrdf.rio.RDFHandlerException