com.bigdata.rdf.store

Class BigdataTriplePatternMaterializer

java.lang.Object

com.bigdata.striterator.AbstractChunkedResolverator<BigdataTriplePattern,ISPO,AbstractTripleStore>

com.bigdata.rdf.store.BigdataTriplePatternMaterializer

All Implemented Interfaces:

ICloseable, ICloseableIterator<ISPO>, Iterator<ISPO>

public class BigdataTriplePatternMaterializer
extends AbstractChunkedResolverator<BigdataTriplePattern,ISPO,AbstractTripleStore>
implements ICloseableIterator<ISPO>

Efficient batched, streaming resolution of triple patterns to statements spanned by those triple patterns that are present in the data.

Note: If the input contains triple patterns that have a high cardinality in the data, then a large number of statements may be returned.

See Also:

Efficient batch remove of a collection of triple patterns

Field Summary

Fields inherited from class com.bigdata.striterator.AbstractChunkedResolverator

state

Constructor Summary

Constructors

Constructor and Description
BigdataTriplePatternMaterializer(AbstractTripleStore db, IChunkedOrderedIterator<BigdataTriplePattern> src)
BigdataTriplePatternMaterializer(AbstractTripleStore db, IChunkedOrderedIterator<BigdataTriplePattern> src, int nthreads)

Method Summary

Methods

Modifier and Type	Method and Description
protected ISPO[]	resolveChunk(BigdataTriplePattern[] chunk) Resolves the elements in a source chunk, returning a chunk of resolved elements.
BigdataTriplePatternMaterializer	start(ExecutorService service) Creates and runs a task that will consume chunks from the source iterator, resolve the elements in each chunk, and place the resolved chunks onto the BlockingBuffer.

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 cutthecrap.utils.striterators.ICloseableIterator

close

Methods inherited from interface java.util.Iterator

hasNext, next, remove

Constructor Detail

BigdataTriplePatternMaterializer

public BigdataTriplePatternMaterializer(AbstractTripleStore db,
                                IChunkedOrderedIterator<BigdataTriplePattern> src)

BigdataTriplePatternMaterializer

public BigdataTriplePatternMaterializer(AbstractTripleStore db,
                                IChunkedOrderedIterator<BigdataTriplePattern> src,
                                int nthreads)

Method Detail

start

public BigdataTriplePatternMaterializer start(ExecutorService service)

Description copied from class: AbstractChunkedResolverator

Creates and runs a task that will consume chunks from the source iterator, resolve the elements in each chunk, and place the resolved chunks onto the BlockingBuffer.

You MUST invoke this before consuming results from the iterator.

Implementations SHOULD strengthen the return type.

Overrides:

start in class AbstractChunkedResolverator<BigdataTriplePattern,ISPO,AbstractTripleStore>

Parameters:

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

resolveChunk

protected ISPO[] resolveChunk(BigdataTriplePattern[] chunk)

Description copied from class: AbstractChunkedResolverator

Resolves the elements in a source chunk, returning a chunk of resolved elements.

Note: This method is invoked by the ChunkConsumerTask which runs asynchronously.

Specified by:

resolveChunk in class AbstractChunkedResolverator<BigdataTriplePattern,ISPO,AbstractTripleStore>

Parameters:

chunk - The next chunk from the source iterator.

Returns:

The resolved chunk.