com.bigdata.rdf.store

Class BigdataOpenRDFBindingSetsResolverator

java.lang.Object

com.bigdata.striterator.AbstractChunkedResolverator<org.openrdf.query.BindingSet,IBindingSet,AbstractTripleStore>

com.bigdata.rdf.store.BigdataOpenRDFBindingSetsResolverator

All Implemented Interfaces:

ICloseable, ICloseableIterator<IBindingSet>, Iterator<IBindingSet>

public class BigdataOpenRDFBindingSetsResolverator
extends AbstractChunkedResolverator<org.openrdf.query.BindingSet,IBindingSet,AbstractTripleStore>

Efficiently resolve openrdf BindingSets to bigdata IBindingSets (this is a streaming API).

Version:

$Id: BigdataOpenRDFBindingSetsResolverator.java 6151 2012-03-16 17:56:22Z thompsonbry $

Author:

Bryan Thompson

See Also:

BigdataValueReplacer

Field Summary

Fields inherited from class com.bigdata.striterator.AbstractChunkedResolverator

state

Constructor Summary

Constructors

Constructor and Description
BigdataOpenRDFBindingSetsResolverator(AbstractTripleStore db, IChunkedOrderedIterator<org.openrdf.query.BindingSet> src)

Method Summary

Methods

Modifier and Type	Method and Description
protected IBindingSet[]	resolveChunk(org.openrdf.query.BindingSet[] chunk) Resolve a chunk of BindingSets into a chunk of IBindingSets in which RDF Values have been resolved to IVs.
static IBindingSet[]	resolveChunk(LexiconRelation r, org.openrdf.query.BindingSet[] chunk) Resolve a chunk of BindingSets into a chunk of IBindingSets in which RDF Values have been resolved to IVs.
BigdataOpenRDFBindingSetsResolverator	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

BigdataOpenRDFBindingSetsResolverator

public BigdataOpenRDFBindingSetsResolverator(AbstractTripleStore db,
                                     IChunkedOrderedIterator<org.openrdf.query.BindingSet> src)

Parameters:

db - Used to resolve RDF Values to IVs.

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. [Is this comment relevant for this class?]

Method Detail

start

public BigdataOpenRDFBindingSetsResolverator start(ExecutorService service)

Strengthens the return type.

Overrides:

start in class AbstractChunkedResolverator<org.openrdf.query.BindingSet,IBindingSet,AbstractTripleStore>

Parameters:

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

resolveChunk

protected IBindingSet[] resolveChunk(org.openrdf.query.BindingSet[] chunk)

Resolve a chunk of BindingSets into a chunk of IBindingSets in which RDF Values have been resolved to IVs.

Specified by:

resolveChunk in class AbstractChunkedResolverator<org.openrdf.query.BindingSet,IBindingSet,AbstractTripleStore>

Parameters:

chunk - The next chunk from the source iterator.

Returns:

The resolved chunk.

resolveChunk

public static IBindingSet[] resolveChunk(LexiconRelation r,
                         org.openrdf.query.BindingSet[] chunk)

Resolve a chunk of BindingSets into a chunk of IBindingSets in which RDF Values have been resolved to IVs.