com.bigdata.rdf.load

Class VerifyStatementBuffer

java.lang.Object

com.bigdata.rdf.rio.StatementBuffer

com.bigdata.rdf.load.VerifyStatementBuffer

All Implemented Interfaces:

ICounterSetAccess, IStatementBuffer, IBuffer

public class VerifyStatementBuffer
extends StatementBuffer

Statements inserted into the buffer are verified against the database. No new Values or Statements will be written on the database by this class. The #of URI, Literal, and told triples not found in the database are reported by various counters.

Version:

$Id$

Author:

Bryan Thompson

Nested Class Summary

Nested classes/interfaces inherited from class com.bigdata.rdf.rio.StatementBuffer

StatementBuffer.IWrittenSPOArray

Field Summary

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

database, didWriteCallback, numBNodes, numLiterals, numSIDs, numStmts, numURIs, numValues, stmts, valueFactory, values

Constructor Summary

Constructors

Constructor and Description
VerifyStatementBuffer(AbstractTripleStore database, int capacity, AtomicLong nterms, AtomicLong ntermsNotFound, AtomicLong ntriples, AtomicLong ntriplesNotFound)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	incrementalWrite() Overridden to batch verify the terms and statements in the buffer.

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

_clear, add, add, add, add, finalize, flush, getCapacity, getCounters, getDatabase, getQueueCapacity, getStatementStore, handleStatement, isEmpty, nearCapacity, reset, setBNodeMap, setChangeLog, setReadOnly, size, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

VerifyStatementBuffer

public VerifyStatementBuffer(AbstractTripleStore database,
                     int capacity,
                     AtomicLong nterms,
                     AtomicLong ntermsNotFound,
                     AtomicLong ntriples,
                     AtomicLong ntriplesNotFound)

Parameters:

database -

capacity -

Method Detail

incrementalWrite

protected void incrementalWrite()

Overridden to batch verify the terms and statements in the buffer. FIXME Verify that StatementBuffer.flush() is doing the right thing for this case (esp, how it handles bnodes when appearing as {s,p,o} or when appearing as the statement identifier).

Overrides:

incrementalWrite in class StatementBuffer