com.bigdata.rdf.store

Class BigdataSolutionResolverator

java.lang.Object

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

com.bigdata.rdf.store.BigdataSolutionResolverator

All Implemented Interfaces:

ICloseable, ICloseableIterator<IBindingSet>, Iterator<IBindingSet>

public class BigdataSolutionResolverator
extends AbstractChunkedResolverator<ISolution,IBindingSet,AbstractTripleStore>

Efficiently resolve term identifiers in Bigdata ISolutions 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
BigdataSolutionResolverator(AbstractTripleStore db, IChunkedOrderedIterator<ISolution> src)

Method Summary

Methods

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

BigdataSolutionResolverator

public BigdataSolutionResolverator(AbstractTripleStore db,
                           IChunkedOrderedIterator<ISolution> src)

Parameters:

db - Used to resolve term identifiers to Value objects.

src - The source iterator (will be closed when this iterator is closed). 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 BigdataSolutionResolverator start(ExecutorService service)

Strengthens the return type.

Overrides:

start in class AbstractChunkedResolverator<ISolution,IBindingSet,AbstractTripleStore>

Parameters:

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

resolveChunk

protected IBindingSet[] resolveChunk(ISolution[] chunk)

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

Specified by:

resolveChunk in class AbstractChunkedResolverator<ISolution,IBindingSet,AbstractTripleStore>

Parameters:

chunk - The next chunk from the source iterator.

Returns:

The resolved chunk.