com.bigdata.rdf.store

Class BigdataStatementIteratorImpl

java.lang.Object

com.bigdata.striterator.AbstractChunkedResolverator<ISPO,BigdataStatement,AbstractTripleStore>

com.bigdata.rdf.store.BigdataStatementIteratorImpl

All Implemented Interfaces:

BigdataStatementIterator, ICloseable, ICloseableIterator<BigdataStatement>, Iterator<BigdataStatement>

public class BigdataStatementIteratorImpl
extends AbstractChunkedResolverator<ISPO,BigdataStatement,AbstractTripleStore>
implements BigdataStatementIterator

Efficiently resolve term identifiers in Bigdata ISPOs to RDF BigdataValues.

Version:

$Id$

Author:

Bryan Thompson

Field Summary

Fields inherited from class com.bigdata.striterator.AbstractChunkedResolverator

state

Constructor Summary

Constructors

Constructor and Description
BigdataStatementIteratorImpl(AbstractTripleStore db, IChunkedOrderedIterator<ISPO> src)
BigdataStatementIteratorImpl(AbstractTripleStore db, Map<IV,BigdataBNode> bnodes, IChunkedOrderedIterator<ISPO> src)

Method Summary

Methods

Modifier and Type	Method and Description
protected BigdataStatement[]	resolveChunk(ISPO[] chunk) Resolve a chunk of ISPOs into a chunk of BigdataStatements.
BigdataStatementIteratorImpl	start(ExecutorService service) Strengthens the return type.

Methods inherited from class com.bigdata.striterator.AbstractChunkedResolverator

close, hasNext, next, remove

Methods inherited from class java.lang.Object

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

Methods inherited from interface cutthecrap.utils.striterators.ICloseableIterator

close

Methods inherited from interface java.util.Iterator

hasNext, next, remove

Constructor Detail

BigdataStatementIteratorImpl

public BigdataStatementIteratorImpl(AbstractTripleStore db,
                            IChunkedOrderedIterator<ISPO> src)

Parameters:

db - Used to resolve term identifiers to Value objects.

src - The source iterator (will be closed when this iterator is closed).

BigdataStatementIteratorImpl

public BigdataStatementIteratorImpl(AbstractTripleStore db,
                            Map<IV,BigdataBNode> bnodes,
                            IChunkedOrderedIterator<ISPO> src)

Parameters:

db - Used to resolve term identifiers to Value objects.

bnodes - An optional map of known blank node term identifiers and the corresponding BigdataBNodeImpl objects. This map may be used to resolve blank node term identifiers to blank node objects across a "connection" context.

src - The source iterator (will be closed when this iterator is closed).

Method Detail

start

public BigdataStatementIteratorImpl start(ExecutorService service)

Strengthens the return type.

Overrides:

start in class AbstractChunkedResolverator<ISPO,BigdataStatement,AbstractTripleStore>

Parameters:

service - The service on which the task will be executed.

resolveChunk

protected BigdataStatement[] resolveChunk(ISPO[] chunk)

Resolve a chunk of ISPOs into a chunk of BigdataStatements.

Specified by:

resolveChunk in class AbstractChunkedResolverator<ISPO,BigdataStatement,AbstractTripleStore>

Parameters:

chunk - The next chunk from the source iterator.

Returns:

The resolved chunk.