com.bigdata.rdf.store
Class BigdataSolutionResolverator

java.lang.Object
  com.bigdata.striterator.AbstractChunkedResolverator<ISolution,IBindingSet,AbstractTripleStore>
      com.bigdata.rdf.store.BigdataSolutionResolverator

All Implemented Interfaces:

ICloseableIterator<IBindingSet>, Iterator<IBindingSet>

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

Efficiently resolve term identifiers in Bigdata ISolutions to RDF BigdataValues.

Version:

$Id: BigdataSolutionResolverator.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

BigdataSolutionResolverator(AbstractTripleStore db, IChunkedOrderedIterator<ISolution> src)

Method Summary

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.