com.bigdata.rdf.load

Class SingleResourceReaderTask

java.lang.Object

com.bigdata.rdf.load.SingleResourceReaderTask

All Implemented Interfaces:

Runnable

public class SingleResourceReaderTask
extends Object
implements Runnable

Tasks either loads a RDF resource or verifies that the told triples found in that resource are present in the database. The difference between data load and data verify is just the behavior of the IStatementBuffer.

Version:

$Id$

Author:

Bryan Thompson

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.apache.log4j.Logger	log

Constructor Summary

Constructors

Constructor and Description
SingleResourceReaderTask(String resource, String baseURL, org.openrdf.rio.RDFFormat rdfFormat, RDFParserOptions parserOptions, boolean deleteAfter, IStatementBufferFactory bufferFactory, AtomicLong toldTriples) Note: Updates to toldTriples MUST NOT occur unless the task succeeds, otherwise tasks which error and then retry will cause double-counting.

Method Summary

Methods

Modifier and Type	Method and Description
protected LoadStats	readData() Reads an RDF resource and either loads it into the database or verifies that the triples in the resource are found in the database.
void	run()
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final org.apache.log4j.Logger log

Constructor Detail

SingleResourceReaderTask

public SingleResourceReaderTask(String resource,
                        String baseURL,
                        org.openrdf.rio.RDFFormat rdfFormat,
                        RDFParserOptions parserOptions,
                        boolean deleteAfter,
                        IStatementBufferFactory bufferFactory,
                        AtomicLong toldTriples)

Note: Updates to toldTriples MUST NOT occur unless the task succeeds, otherwise tasks which error and then retry will cause double-counting.

Parameters:

resource -

baseURL -

rdfFormat -

verifyData -

deleteAfter -

bufferFactory -

toldTriples -

Method Detail

toString

public String toString()

Overrides:

toString in class Object

run

public void run()

Specified by:

run in interface Runnable

readData

protected LoadStats readData()
                      throws Exception

Reads an RDF resource and either loads it into the database or verifies that the triples in the resource are found in the database.

Throws:

Exception