com.bigdata.rdf.store

Class BigdataBindingSetResolverator

java.lang.Object

com.bigdata.striterator.AbstractChunkedResolverator<IBindingSet,IBindingSet,AbstractTripleStore>

com.bigdata.rdf.store.BigdataBindingSetResolverator

All Implemented Interfaces:

ICloseable, ICloseableIterator<IBindingSet>, Iterator<IBindingSet>

public class BigdataBindingSetResolverator
extends AbstractChunkedResolverator<IBindingSet,IBindingSet,AbstractTripleStore>

Efficiently resolve term identifiers in Bigdata IBindingSets to RDF BigdataValues.

Version:

$Id: BigdataSolutionResolverator.java 3448 2010-08-18 20:55:58Z thompsonbry $

Author:

Bryan Thompson

See Also:

ChunkedMaterializationOp

Field Summary

Fields inherited from class com.bigdata.striterator.AbstractChunkedResolverator

state

Constructor Summary

Constructors

Constructor and Description
BigdataBindingSetResolverator(AbstractTripleStore db, IChunkedOrderedIterator<IBindingSet> src, UUID queryId, IVariable[] required, int chunkOfChunksCapacity, int chunkCapacity, long chunkTimeout, int termsChunkSize, int blobsChunkSize)

Method Summary

Methods

Modifier and Type	Method and Description
protected IBindingSet[]	resolveChunk(IBindingSet[] chunk) Resolve a chunk of IBindingSets into a chunk of IBindingSets in which term identifiers have been resolved to BigdataValues.
BigdataBindingSetResolverator	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

Constructor Detail

BigdataBindingSetResolverator

public BigdataBindingSetResolverator(AbstractTripleStore db,
                             IChunkedOrderedIterator<IBindingSet> src,
                             UUID queryId,
                             IVariable[] required,
                             int chunkOfChunksCapacity,
                             int chunkCapacity,
                             long chunkTimeout,
                             int termsChunkSize,
                             int blobsChunkSize)

Parameters:

db - Used to resolve term identifiers to Value objects.

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

queryId - The query UUID (for logging on the SolutionsLog).

required - The variables to be resolved (optional). When null, all variables will be resolved. FIXME must accept reverse bnodes map (from term identifier to blank nodes) for resolution of blank nodes within a Sesame connection context.

Method Detail

start

public BigdataBindingSetResolverator start(ExecutorService service)

Strengthens the return type.

Overrides:

start in class AbstractChunkedResolverator<IBindingSet,IBindingSet,AbstractTripleStore>

Parameters:

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

resolveChunk

protected IBindingSet[] resolveChunk(IBindingSet[] chunk)

Resolve a chunk of IBindingSets into a chunk of IBindingSets in which term identifiers have been resolved to BigdataValues.

Specified by:

resolveChunk in class AbstractChunkedResolverator<IBindingSet,IBindingSet,AbstractTripleStore>

Parameters:

chunk - The next chunk from the source iterator.

Returns:

The resolved chunk.