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: SingleResourceReaderTask.java 4069 2011-01-09 20:58:02Z thompsonbry $

Author:

Bryan Thompson

Field Summary

protected static org.apache.log4j.Logger

log

Constructor Summary

SingleResourceReaderTask(String resource, String baseURL, 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

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,
                                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