Package | Description |
---|---|
com.bigdata.bop.ap | |
com.bigdata.rdf.changesets | |
com.bigdata.rdf.inf |
This package provides an eager closure inference engine for most of the RDF and
RDFS entailments and can be used to realize entailments for owl:sameAs, owl:equivilentClass,
and owl:equivilentProperty.
|
com.bigdata.rdf.lexicon | |
com.bigdata.rdf.rules | |
com.bigdata.rdf.spo |
This package defines a statement model using long term identifiers rather than
RDF Value objects.
|
com.bigdata.rdf.store |
This package provides several realizations of an RDF database using the bigdata
architecture, including one suitable for temporary data, one suitable for local
processing (single host), and one designed for scale-out on commodity hardware.
|
com.bigdata.relation |
This package includes an abstraction layer for relations.
|
com.bigdata.relation.accesspath |
This package includes an abstraction layer for efficient access paths, including
chunked iterators, blocking buffers, and an abstraction corresponding to the natural
order of an index.
|
com.bigdata.relation.rule.eval |
This package supports rule evaluation.
|
com.bigdata.search |
This package provides full text indexing and search.
|
com.bigdata.service.proxy |
This package provides implementations of proxy objects for commonly used
classes.
|
com.bigdata.striterator |
Streaming iterator patterns based on Martyn Cutcher's striterator design
but supporting generics and with extensions for closable, chunked, and
ordered streaming iterators.
|
Modifier and Type | Method and Description |
---|---|
long |
R.delete(IChunkedOrderedIterator<E> itr)
Simple delete implementation works fine for a local journal.
|
long |
R.insert(IChunkedOrderedIterator<E> itr)
Simple insert procedure works fine for a local journal.
|
Modifier and Type | Method and Description |
---|---|
static long |
StatementWriter.addStatements(AbstractTripleStore database,
AbstractTripleStore statementStore,
boolean copyOnly,
IElementFilter<ISPO> filter,
IChunkedOrderedIterator<ISPO> itr,
IChangeLog changeLog) |
static long |
StatementWriter.removeStatements(AbstractTripleStore database,
IChunkedOrderedIterator<ISPO> itr,
boolean computeClosureForStatementIdentifiers,
IChangeLog changeLog) |
Modifier and Type | Class and Description |
---|---|
class |
BackchainOwlSameAsIterator |
class |
BackchainOwlSameAsPropertiesIterator
Provides backward chaining for property collection and reverse property
collection on owl:sameAs for all access paths.
|
class |
BackchainOwlSameAsPropertiesPIterator
Provides backward chaining for property collection and reverse property
collection on owl:sameAs for the ?P? and ??? access paths.
|
class |
BackchainOwlSameAsPropertiesPOIterator
Provides backward chaining for reverse property collection on owl:sameAs for
the ?PO and ??O access paths.
|
class |
BackchainOwlSameAsPropertiesSPIterator
Provides backward chaining for property collection on owl:sameAs for the SP?
and S?? access paths.
|
class |
BackchainOwlSameAsPropertiesSPOIterator
Provides backward chaining for property collection and reverse property
collection on owl:sameAs for the SPO and S?O access paths.
|
class |
BackchainTypeResourceIterator
Provides backward chaining for (x rdf:type rdfs:Resource).
|
class |
OwlSameAsPropertiesExpandingIterator |
Modifier and Type | Field and Description |
---|---|
protected IChunkedOrderedIterator<ISPO> |
BackchainOwlSameAsIterator.src |
Modifier and Type | Method and Description |
---|---|
static IChunkedOrderedIterator<ISPO> |
BackchainTypeResourceIterator.newInstance(IChunkedOrderedIterator<ISPO> _src,
IAccessPath<ISPO> accessPath,
AbstractTripleStore db,
IV rdfType,
IV rdfsResource)
Returns a suitably configured
BackchainTypeResourceIterator -or-
src iff the accessPath does not require the materialization
of (x rdf:type rdfs:Resource) entailments. |
Modifier and Type | Method and Description |
---|---|
static IChunkedOrderedIterator<ISPO> |
BackchainTypeResourceIterator.newInstance(IChunkedOrderedIterator<ISPO> _src,
IAccessPath<ISPO> accessPath,
AbstractTripleStore db,
IV rdfType,
IV rdfsResource)
Returns a suitably configured
BackchainTypeResourceIterator -or-
src iff the accessPath does not require the materialization
of (x rdf:type rdfs:Resource) entailments. |
Constructor and Description |
---|
BackchainOwlSameAsIterator(IChunkedOrderedIterator<ISPO> src,
AbstractTripleStore db,
IV sameAs) |
BackchainOwlSameAsPropertiesIterator(IChunkedOrderedIterator<ISPO> src,
IV s,
IV p,
IV o,
AbstractTripleStore db,
IV sameAs)
Create an iterator that will visit all statements in the source iterator
and also backchain any entailments that would have resulted from
owl:sameAs {2,3}.
|
BackchainOwlSameAsPropertiesPIterator(IChunkedOrderedIterator<ISPO> src,
IV p,
AbstractTripleStore db,
IV sameAs)
Create an iterator that will visit all statements in the source iterator
and also backchain any entailments that would have resulted from
owl:sameAs {2,3}.
|
BackchainOwlSameAsPropertiesPOIterator(IChunkedOrderedIterator<ISPO> src,
IV p,
IV o,
AbstractTripleStore db,
IV sameAs)
Create an iterator that will visit all statements in the source iterator
and also backchain any entailments that would have resulted from
owl:sameAs {2,3}.
|
BackchainOwlSameAsPropertiesSPIterator(IChunkedOrderedIterator<ISPO> src,
IV s,
IV p,
AbstractTripleStore db,
IV sameAs)
Create an iterator that will visit all statements in the source iterator
and also backchain any entailments that would have resulted from
owl:sameAs {2,3}.
|
BackchainOwlSameAsPropertiesSPOIterator(IChunkedOrderedIterator<ISPO> src,
IV s,
IV p,
IV o,
AbstractTripleStore db,
IV sameAs)
Create an iterator that will visit all statements in the source iterator
and also backchain any entailments that would have resulted from
owl:sameAs {2,3}.
|
Modifier and Type | Method and Description |
---|---|
long |
LexiconRelation.delete(IChunkedOrderedIterator<BigdataValue> itr)
Note : this method is part of the mutation api.
|
long |
LexiconRelation.insert(IChunkedOrderedIterator<BigdataValue> itr)
Note : this method is part of the mutation api.
|
Modifier and Type | Method and Description |
---|---|
IChunkedOrderedIterator<ISPO> |
BackchainAccessPath.iterator()
An iterator visiting elements using the natural order of the index
selected for the
IPredicate . |
IChunkedOrderedIterator<ISPO> |
BackchainAccessPath.iterator(long offset,
long limit,
int capacity)
An iterator visiting elements using the natural order of the index
selected for the
IPredicate . |
Modifier and Type | Method and Description |
---|---|
protected void |
TestSlice.assertSameSolutions(IChunkedOrderedIterator<ISolution> itr,
IBindingSet[] expected)
Verifies the the iterator visits
ISolution s have the expected
IBindingSet s in the expected order. |
protected void |
AbstractRuleTestCase.assertSameSolutionsAnyOrder(IChunkedOrderedIterator<ISolution> itr,
IBindingSet[] expected)
Verifies the the iterator visits
ISolution s have the expected
IBindingSet s when those bindings may occur in any order. |
protected long |
RDFJoinNexus.InsertSPOAndJustificationBuffer.flush(IChunkedOrderedIterator<ISolution<E>> itr) |
Modifier and Type | Class and Description |
---|---|
class |
SPOArrayIterator
Deprecated.
by
ChunkedArrayIterator but this still has some very
purpose specific uses mainly dealing with
TruthMaintenance and with fully buffering precisely
because the DB impl is not using concurrency controls. |
Modifier and Type | Method and Description |
---|---|
protected void |
TestSPOStarJoin.compare(IChunkedOrderedIterator<ISolution> result,
Collection<IBindingSet> answer) |
ISPO[] |
BulkFilterConverter.convert(IChunkedOrderedIterator<ISPO> src) |
ISPO[] |
BulkCompleteConverter.convert(IChunkedOrderedIterator<ISPO> src) |
long |
SPORelation.delete(IChunkedOrderedIterator<ISPO> itr)
Deletes
SPO s, writing on the statement indices in parallel. |
long |
SPORelation.insert(IChunkedOrderedIterator<ISPO> itr)
Inserts
SPO s, writing on the statement indices in parallel. |
Constructor and Description |
---|
StatementWriter(AbstractTripleStore database,
AbstractTripleStore statementStore,
boolean copyOnly,
IChunkedOrderedIterator<ISPO> itr,
AtomicLong nwritten)
Deprecated.
|
StatementWriter(AbstractTripleStore database,
AbstractTripleStore statementStore,
boolean copyOnly,
IChunkedOrderedIterator<ISPO> itr,
AtomicLong nwritten,
IChangeLog changeLog)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
IChunkedOrderedIterator<ISPO> |
IRawTripleStore.bulkCompleteStatements(IChunkedOrderedIterator<ISPO> itr)
This method fills out the statement metadata (type and sid) for
ISPO s that are present in the database. |
IChunkedOrderedIterator<ISPO> |
AbstractTripleStore.bulkCompleteStatements(IChunkedOrderedIterator<ISPO> itr) |
IChunkedOrderedIterator<ISPO> |
AbstractTripleStore.bulkCompleteStatements(SPO[] stmts,
int numStmts) |
IChunkedOrderedIterator<ISPO> |
IRawTripleStore.bulkFilterStatements(IChunkedOrderedIterator<ISPO> itr,
boolean present)
Efficiently filter the supplied set of
SPO objects for whether
they are "present" or "not present" in the database, depending on the
value of the supplied boolean variable (batch api). |
IChunkedOrderedIterator<ISPO> |
AbstractTripleStore.bulkFilterStatements(IChunkedOrderedIterator<ISPO> itr,
boolean present) |
IChunkedOrderedIterator<ISPO> |
IRawTripleStore.bulkFilterStatements(ISPO[] stmts,
int numStmts,
boolean present)
Filter the supplied set of
ISPO objects for whether they are
"present" or "not present" in the database, depending on the value of the
supplied boolean variable (batch API). |
IChunkedOrderedIterator<ISPO> |
AbstractTripleStore.bulkFilterStatements(ISPO[] stmts,
int numStmts,
boolean present) |
IChunkedOrderedIterator<ISPO> |
AbstractTripleStore.computeClosureForStatementIdentifiers(IChunkedOrderedIterator<ISPO> src)
Return an iterator which will visit the closure of the statements visited
by the source iterator plus any statements in the database made using a
statement identifier found on any of the statements visited by the source
iterator (only explicit statements have statement identifiers and then
iff
AbstractTripleStore.statementIdentifiers are enabled). |
Modifier and Type | Method and Description |
---|---|
long |
AbstractTripleStore.addStatements(AbstractTripleStore statementStore,
boolean copyOnly,
IChunkedOrderedIterator<ISPO> itr,
IElementFilter<ISPO> filter)
Add statements to the statementStore.
|
long |
IRawTripleStore.addStatements(IChunkedOrderedIterator<ISPO> itr,
IElementFilter<ISPO> filter)
Deprecated.
|
long |
AbstractTripleStore.addStatements(IChunkedOrderedIterator<ISPO> itr,
IElementFilter<ISPO> filter) |
static void |
AbstractTestCase.assertSameSPOs(ISPO[] expected,
IChunkedOrderedIterator<ISPO> actual) |
static void |
AbstractTestCase.assertSameSPOs(String msg,
ISPO[] expected,
IChunkedOrderedIterator<ISPO> actual) |
static void |
AbstractTestCase.assertSameSPOsAnyOrder(AbstractTripleStore store,
ISPO[] expected,
IChunkedOrderedIterator<ISPO> actual)
Verify that the iterator visits the expected
ISPO s in any order
without duplicates. |
static void |
AbstractTestCase.assertSameSPOsAnyOrder(AbstractTripleStore store,
ISPO[] expected,
IChunkedOrderedIterator<ISPO> actual,
boolean ignoreAxioms)
Verify that the iterator visits the expected
ISPO s in any order
without duplicates, optionally ignoring axioms. |
BigdataStatementIterator |
ITripleStore.asStatementIterator(IChunkedOrderedIterator<ISPO> src)
Wraps an
IChunkedOrderedIterator as a
BigdataStatementIterator . |
BigdataStatementIterator |
AbstractTripleStore.asStatementIterator(IChunkedOrderedIterator<ISPO> src) |
IChunkedOrderedIterator<ISPO> |
IRawTripleStore.bulkCompleteStatements(IChunkedOrderedIterator<ISPO> itr)
This method fills out the statement metadata (type and sid) for
ISPO s that are present in the database. |
IChunkedOrderedIterator<ISPO> |
AbstractTripleStore.bulkCompleteStatements(IChunkedOrderedIterator<ISPO> itr) |
IChunkedOrderedIterator<ISPO> |
IRawTripleStore.bulkFilterStatements(IChunkedOrderedIterator<ISPO> itr,
boolean present)
Efficiently filter the supplied set of
SPO objects for whether
they are "present" or "not present" in the database, depending on the
value of the supplied boolean variable (batch api). |
IChunkedOrderedIterator<ISPO> |
AbstractTripleStore.bulkFilterStatements(IChunkedOrderedIterator<ISPO> itr,
boolean present) |
IChunkedOrderedIterator<ISPO> |
AbstractTripleStore.computeClosureForStatementIdentifiers(IChunkedOrderedIterator<ISPO> src)
Return an iterator which will visit the closure of the statements visited
by the source iterator plus any statements in the database made using a
statement identifier found on any of the statements visited by the source
iterator (only explicit statements have statement identifiers and then
iff
AbstractTripleStore.statementIdentifiers are enabled). |
BigdataStatementIterator |
AbstractTripleStore.getStatements(IChunkedOrderedIterator<BigdataTriplePattern> triplePatterns)
Efficient batched, streaming resolution of triple patterns to statements
spanned by those triple patterns that are present in the data.
|
long |
IRawTripleStore.removeStatements(IChunkedOrderedIterator<ISPO> itr)
Removes the statements from the statement indices (batch, parallel, NO
truth maintenance).
|
long |
AbstractTripleStore.removeStatements(IChunkedOrderedIterator<ISPO> itr) |
long |
AbstractTripleStore.removeStatements(IChunkedOrderedIterator<ISPO> itr,
boolean computeClosureForStatementIdentifiers)
This processes a chunk of
SPO s at a time and then submits tasks
to parallel threads to remove those statements from each of the statement
indices. |
Constructor and Description |
---|
BigdataBindingSetResolverator(AbstractTripleStore db,
IChunkedOrderedIterator<IBindingSet> src,
UUID queryId,
IVariable[] required,
int chunkOfChunksCapacity,
int chunkCapacity,
long chunkTimeout,
int termsChunkSize,
int blobsChunkSize) |
BigdataOpenRDFBindingSetsResolverator(AbstractTripleStore db,
IChunkedOrderedIterator<org.openrdf.query.BindingSet> src) |
BigdataSolutionResolverator(AbstractTripleStore db,
IChunkedOrderedIterator<ISolution> src) |
BigdataStatementIteratorImpl(AbstractTripleStore db,
IChunkedOrderedIterator<ISPO> src) |
BigdataStatementIteratorImpl(AbstractTripleStore db,
Map<IV,BigdataBNode> bnodes,
IChunkedOrderedIterator<ISPO> src) |
BigdataTriplePatternMaterializer(AbstractTripleStore db,
IChunkedOrderedIterator<BigdataTriplePattern> src) |
BigdataTriplePatternMaterializer(AbstractTripleStore db,
IChunkedOrderedIterator<BigdataTriplePattern> src,
int nthreads) |
Modifier and Type | Method and Description |
---|---|
long |
IMutableRelation.delete(IChunkedOrderedIterator<E> itr)
Remove elements from the relation.
|
long |
IMutableRelation.insert(IChunkedOrderedIterator<E> itr)
Write elements on the relation.
|
Modifier and Type | Class and Description |
---|---|
class |
ChunkConsumerIterator<E>
A class that aligns a buffer of
E[] s (a buffer of chunks) with
an IChunkedOrderedIterator . |
Modifier and Type | Method and Description |
---|---|
protected IChunkedOrderedIterator<R> |
AccessPath.asynchronousIterator(Iterator<R> src)
Asynchronous read using a
BlockingBuffer . |
IChunkedOrderedIterator<R> |
AccessPath.iterator() |
IChunkedOrderedIterator<E> |
UnsynchronizedUnboundedChunkBuffer.iterator()
Iterator drains chunks from a snapshot of the queue (shallow copy).
|
IChunkedOrderedIterator<E> |
AccessPathFusedView.iterator()
Deprecated.
|
IChunkedOrderedIterator<R> |
IAccessPath.iterator()
An iterator visiting elements using the natural order of the index
selected for the
IPredicate . |
IChunkedOrderedIterator<E> |
EmptyAccessPath.iterator()
Visits nothing.
|
IChunkedOrderedIterator<E> |
ArrayAccessPath.iterator()
An iterator visiting elements using the natural order of the index
selected for the
IPredicate . |
IChunkedOrderedIterator<R> |
AccessPath.iterator(long offset,
long limit,
int capacity) |
IChunkedOrderedIterator<E> |
AccessPathFusedView.iterator(long offset,
long limit,
int capacity)
Deprecated.
FIXME write tests for optimizations for point tests and small limits.
|
IChunkedOrderedIterator<R> |
IAccessPath.iterator(long offset,
long limit,
int capacity)
An iterator visiting elements using the natural order of the index
selected for the
IPredicate . |
IChunkedOrderedIterator<E> |
EmptyAccessPath.iterator(long offset,
long limit,
int capacity)
Visits nothing.
|
IChunkedOrderedIterator<E> |
ArrayAccessPath.iterator(long offset,
long limit,
int capacity)
An iterator visiting elements using the natural order of the index
selected for the
IPredicate . |
protected IChunkedOrderedIterator<R> |
AccessPath.synchronousIterator(long offset,
long limit,
Iterator<R> src)
Fully buffers all elements that would be visited by the
IAccessPath iterator. |
Modifier and Type | Method and Description |
---|---|
protected abstract long |
AbstractElementBuffer.flush(IChunkedOrderedIterator<R> itr)
Concrete implementations must process the elements, causing the
appropriate mutation on the target
IRelation . |
protected long |
AbstractElementBuffer.InsertBuffer.flush(IChunkedOrderedIterator<R> itr) |
protected long |
AbstractElementBuffer.DeleteBuffer.flush(IChunkedOrderedIterator<R> itr) |
Modifier and Type | Method and Description |
---|---|
IChunkedOrderedIterator<ISolution> |
AbstractJoinNexus.runQuery(IStep step) |
IChunkedOrderedIterator<ISolution> |
IJoinNexus.runQuery(IStep step)
Run as a query.
|
Modifier and Type | Method and Description |
---|---|
protected long |
AbstractSolutionBuffer.InsertSolutionBuffer.flush(IChunkedOrderedIterator<ISolution<E>> itr) |
protected long |
AbstractSolutionBuffer.DeleteSolutionBuffer.flush(IChunkedOrderedIterator<ISolution<E>> itr) |
protected abstract long |
AbstractSolutionBuffer.flush(IChunkedOrderedIterator<ISolution<R>> itr)
|
Modifier and Type | Method and Description |
---|---|
long |
FullTextIndex.delete(IChunkedOrderedIterator itr) |
long |
FullTextIndex.insert(IChunkedOrderedIterator itr) |
Modifier and Type | Class and Description |
---|---|
class |
WrappedRemoteChunkedIterator<E>
Wraps an
IRemoteChunkedIterator so that it looks like an
IChunkedOrderedIterator again. |
Modifier and Type | Class and Description |
---|---|
class |
ChunkedOrderedStriterator<I extends IChunkedOrderedIterator<E>,E>
Chunked ordered streaming iterator.
|
interface |
IChunkedOrderedStriterator<I extends IChunkedOrderedIterator<E>,E>
Generic-enabled streaming iterator pattern for chunked ordered iterators.
|
Modifier and Type | Interface and Description |
---|---|
interface |
IChunkedOrderedStriterator<I extends IChunkedOrderedIterator<E>,E>
Generic-enabled streaming iterator pattern for chunked ordered iterators.
|
Modifier and Type | Class and Description |
---|---|
class |
ChunkedArrayIterator<E>
Fully buffered iterator.
|
class |
ChunkedArraysIterator<E>
An iterator that visits the elements in the given iterator of arrays.
|
class |
ChunkedConvertingIterator<E,F>
Supports the chunk-at-a-time filter and conversion operations.
|
class |
ChunkedOrderedStriterator<I extends IChunkedOrderedIterator<E>,E>
Chunked ordered streaming iterator.
|
class |
ChunkedResolvingIterator<E,S>
Converts the type of the source iterator using
ChunkedResolvingIterator.resolve(Object) . |
class |
ChunkedWrappedIterator<E>
Converts an
Iterator into chunked iterator. |
class |
DelegateChunkedIterator<E>
Abstract class for delegation patterns for chunked iterators.
|
class |
EmptyChunkedIterator<E>
An empty iterator.
|
class |
GenericChunkedOrderedStriterator<E>
Chunked ordered streaming iterator class that supresses generic types.
|
class |
SingleValueChunkedIterator<E>
An iterator that will visit a single value.
|
Modifier and Type | Method and Description |
---|---|
IChunkedOrderedIterator<F> |
ChunkedFilter.filter(I src)
Wrap the source iterator with an iterator that applies this filter.
|
Modifier and Type | Method and Description |
---|---|
E[] |
DistinctFilter.convert(IChunkedOrderedIterator<E> src)
Deprecated.
|
F[] |
IChunkConverter.convert(IChunkedOrderedIterator<E> src)
Convert the next chunk of element(s) from the source iterator into target
element(s).
|
protected F[] |
ChunkedConvertingIterator.convert(IChunkedOrderedIterator<E> src)
Applies the chunk-at-a-time converter.
|
Constructor and Description |
---|
AbstractChunkedResolverator(S state,
IChunkedOrderedIterator<E> src,
BlockingBuffer<F[]> buffer) |
ChunkedConvertingIterator(IChunkedOrderedIterator<E> src,
IChunkConverter<E,F> converter)
Ctor when the element type is NOT being changed during conversion.
|
ChunkedConvertingIterator(IChunkedOrderedIterator<E> src,
IChunkConverter<E,F> converter,
IKeyOrder<F> keyOrder)
Variant ctor when you are also converting the element type.
|
ChunkedResolvingIterator(IChunkedOrderedIterator<S> src)
Ctor variant when resolving changes the sort order such that the resolved
elements would need to be sorted to put them into a known order.
|
ChunkedResolvingIterator(IChunkedOrderedIterator<S> src,
IKeyOrder<E> keyOrder)
Ctor variant when (a) you KNOW the sort order for the source iterator and
(b) the source elements and the resolved elements have the same natural
sort order (so the sort order is naturally preserved when the elements
are resolved).
|
DelegateChunkedIterator(IChunkedOrderedIterator<E> src) |
GenericChunkedOrderedStriterator(IChunkedOrderedIterator<E> src) |
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.