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, ICloseableIterator<BigdataStatement>, Iterator<BigdataStatement>

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

Efficiently resolve term identifiers in Bigdata ISolutions to RDF BigdataValues.

Version:

$Id: BigdataStatementIteratorImpl.java 4837 2011-07-05 13:31:31Z thompsonbry $

Author:

Bryan Thompson

Field Summary

Fields inherited from class com.bigdata.striterator.AbstractChunkedResolverator

state

Constructor Summary

BigdataStatementIteratorImpl(AbstractTripleStore db, IChunkedOrderedIterator<ISPO> src)

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

Method Summary

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 com.bigdata.striterator.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.