com.bigdata.rdf.spo
Class StatementWriter

java.lang.Object
  com.bigdata.rdf.spo.StatementWriter

All Implemented Interfaces:

Callable<Long>

Deprecated. by SPORelation.insert(IChunkedOrderedIterator)? (Still used by copyStatements)

public class StatementWriter
extends Object
implements Callable<Long>

Writes statements on all the statement indices in parallel.

Version:

$Id: StatementWriter.java 4065 2011-01-06 21:02:44Z thompsonbry $

Author:

Bryan Thompson

Field Summary

protected static org.apache.log4j.Logger	log Deprecated.
AtomicLong	nwritten Deprecated. Incremented by the #of statements written on the statements indices.

Constructor Summary

StatementWriter(AbstractTripleStore database, AbstractTripleStore statementStore, boolean copyOnly, IChunkedOrderedIterator<ISPO> itr, AtomicLong nwritten)
Deprecated.

StatementWriter(AbstractTripleStore database, AbstractTripleStore statementStore, boolean copyOnly, IChunkedOrderedIterator<ISPO> itr, AtomicLong nwritten, IChangeLog changeLog)
Deprecated.

Method Summary

Long	call() Deprecated. Writes on the statement indices (parallel, batch api).

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final org.apache.log4j.Logger log

Deprecated.

nwritten

public final AtomicLong nwritten

Deprecated.

Incremented by the #of statements written on the statements indices.

Constructor Detail

StatementWriter

public StatementWriter(AbstractTripleStore database,
                       AbstractTripleStore statementStore,
                       boolean copyOnly,
                       IChunkedOrderedIterator<ISPO> itr,
                       AtomicLong nwritten)

Deprecated.

Parameters:

database - The database. If statement identifiers are being generated then they will always be added using the lexicon associated with the database.

statementStore - The store on which the statements will be written (the focus store if you are doing truth maintenance and otherwise the database).

copyOnly - See {@link AbstractTripleStore#addStatements(AbstractTripleStore, boolean, IChunkedOrderedIterator, IElementFilter)

itr - The source iterator for the SPOs to be written.

nwritten - Incremented by the #of statements written on the statement indices as a side-effect.

TODO:

allow an optional IElementFilter here.

StatementWriter

public StatementWriter(AbstractTripleStore database,
                       AbstractTripleStore statementStore,
                       boolean copyOnly,
                       IChunkedOrderedIterator<ISPO> itr,
                       AtomicLong nwritten,
                       IChangeLog changeLog)

Deprecated.

Method Detail

call

public Long call()
          throws Exception

Deprecated.

Writes on the statement indices (parallel, batch api).

Specified by:

call in interface Callable<Long>

Returns:

The elapsed time for the operation.

Throws:

Exception