Package | Description |
---|---|
com.bigdata.bop |
This package provides an API for query operators.
|
com.bigdata.bop.engine | |
com.bigdata.rdf.axioms | |
com.bigdata.rdf.changesets | |
com.bigdata.rdf.graph.impl.bd | |
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.load |
Support for concurrent loading of RDF data across one or more clients from
a variety of input sources.
|
com.bigdata.rdf.rio |
This package provides an integration with the openrdf RIO parser that supports
fast data loads.
|
com.bigdata.rdf.rules | |
com.bigdata.rdf.sail |
This package contains the SAIL that allow bigdata to be used as a backend for
the Sesame 2.x platform.
|
com.bigdata.rdf.sail.bench | |
com.bigdata.rdf.sail.sparql |
This package was imported from the
org.openrdf.query.parser.sparql
package of the openrdf distribution. |
com.bigdata.rdf.sail.webapp | |
com.bigdata.rdf.sparql | |
com.bigdata.rdf.sparql.ast |
This package contains an Abstract Syntax Tree which provides an intermediate translation
target for SPARQL parsers.
|
com.bigdata.rdf.sparql.ast.eval | |
com.bigdata.rdf.sparql.ast.service |
This package provides support for SPARQL 1.1 Federated Query, including the
special case of "service" end points which live within the same JVM and use
direct method calls rather than SPARQL Query and remote (HTTP) end points
for which we will generate an appropriate SPARQL query.
|
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.rdf.util |
Modifier and Type | Method and Description |
---|---|
static AbstractTripleStore |
TestMockUtility.mockTripleStore(String namespace)
Creates a mocked local triple (memory) store with the given namespace,
with unisolated transactions.
|
Modifier and Type | Method and Description |
---|---|
static BOpContext<IBindingSet> |
TestMockUtility.mockContext(AbstractTripleStore kb)
Creates a mocked context associated with the given abstract triple store,
with index manager properly initialized.
|
Modifier and Type | Method and Description |
---|---|
static void |
AbstractQueryEngineTestCase.compareTupleQueryResults(String name,
String testURI,
AbstractTripleStore store,
ASTContainer astContainer,
org.openrdf.query.TupleQueryResult queryResult,
org.openrdf.query.TupleQueryResult expectedResult,
boolean laxCardinality,
boolean checkOrder)
Utility method compares expected and actual solutions and reports on any
discrepancies.
|
Modifier and Type | Method and Description |
---|---|
void |
BaseAxioms.init(AbstractTripleStore db)
Uses
BaseAxioms.addAxioms(Collection) to collect the declared axioms and
then writes the axioms onto the database specified to the
BaseAxioms#BaseAxioms(AbstractTripleStore) ctor. |
Modifier and Type | Method and Description |
---|---|
static long |
StatementWriter.addStatements(AbstractTripleStore database,
AbstractTripleStore statementStore,
boolean copyOnly,
IElementFilter<ISPO> filter,
IChunkedOrderedIterator<ISPO> itr,
IChangeLog changeLog) |
Collection<IChangeRecord> |
InMemChangeLog.getLastCommit(AbstractTripleStore db)
Return the change set as of the last commmit point, using the supplied
database to resolve ISPOs to BigdataStatements.
|
static long |
StatementWriter.removeStatements(AbstractTripleStore database,
IChunkedOrderedIterator<ISPO> itr,
boolean computeClosureForStatementIdentifiers,
IChangeLog changeLog) |
static long |
StatementWriter.removeStatements(AbstractTripleStore database,
ISPO[] stmts,
int numStmts,
boolean computeClosureForStatementIdentifiers,
IChangeLog changeLog) |
Constructor and Description |
---|
InferenceChangeLogReporter(AbstractTripleStore kb) |
Modifier and Type | Method and Description |
---|---|
AbstractTripleStore |
BigdataGASEngine.BigdataGraphAccessor.getKB()
Return a view of the specified graph (aka KB) as of the specified
timestamp.
|
Constructor and Description |
---|
BigdataGraphFixture(AbstractTripleStore kb) |
Modifier and Type | Field and Description |
---|---|
protected AbstractTripleStore |
TruthMaintenance.database
The target database.
|
protected AbstractTripleStore |
BackchainOwlSameAsIterator.db
The database.
|
Modifier and Type | Method and Description |
---|---|
AbstractTripleStore |
TruthMaintenance.getDatabase()
The database whose closure will be updated.
|
AbstractTripleStore |
SPOAssertionBuffer.getFocusStore()
Deprecated.
The focusStore on which the entailments computed by closure will be
written.
|
protected AbstractTripleStore |
AbstractSPOBuffer.getTermDatabase()
Deprecated.
The database in which the term identifiers are defined - this is
exposed ONLY for use in logging messages.
|
Modifier and Type | Method and Description |
---|---|
static int |
TruthMaintenance.applyExistingStatements(AbstractTripleStore focusStore,
AbstractTripleStore database,
IElementFilter<ISPO> filter)
Any statements in the fousStore that are already in the database
are converted to explicit statements (iff they are not already explicit)
and removed from the focusStore as a
side-effect.
|
static int |
TruthMaintenance.applyExistingStatements(AbstractTripleStore focusStore,
AbstractTripleStore database,
IElementFilter<ISPO> filter,
IChangeLog changeLog)
Any statements in the fousStore that are already in the database
are converted to explicit statements (iff they are not already explicit)
and removed from the focusStore as a
side-effect.
|
void |
AbstractSPOBuffer.dump(AbstractTripleStore store)
Deprecated.
Dumps the state of the buffer on
System.err . |
void |
SPOAssertionBuffer.dump(AbstractTripleStore store)
Deprecated.
|
static boolean |
Justification.isGrounded(InferenceEngine inf,
TempTripleStore focusStore,
AbstractTripleStore db,
ISPO head,
boolean testHead,
boolean testFocusStore,
Justification.VisitedSPOSet visited) |
static boolean |
Justification.isGrounded(InferenceEngine inf,
TempTripleStore focusStore,
AbstractTripleStore db,
SPO head,
boolean testHead,
boolean testFocusStore)
Return true iff a grounded justification chain exists for the statement.
|
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. |
String |
Justification.toString(AbstractTripleStore db) |
Constructor and Description |
---|
AbstractSPOBuffer(AbstractTripleStore store,
IElementFilter<ISPO> filter,
int capacity)
Deprecated.
Create a buffer.
|
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}.
|
FullyBufferedJustificationIterator(AbstractTripleStore db,
ISPO head) |
OwlSameAsPropertiesExpandingIterator(IV s,
IV p,
IV o,
AbstractTripleStore db,
IV sameAs,
IKeyOrder<ISPO> keyOrder) |
SPOAssertionBuffer(AbstractTripleStore focusStore,
AbstractTripleStore db,
IElementFilter<ISPO> filter,
int capacity,
boolean justified)
Deprecated.
Create a buffer.
|
SPOAssertionBuffer(AbstractTripleStore focusStore,
AbstractTripleStore db,
IElementFilter<ISPO> filter,
int capacity,
boolean justified,
IChangeLog changeLog)
Deprecated.
Create a buffer.
|
SPORetractionBuffer(AbstractTripleStore store,
int capacity,
boolean computeClosureForStatementIdentifiers)
Deprecated.
|
SPORetractionBuffer(AbstractTripleStore store,
int capacity,
boolean computeClosureForStatementIdentifiers,
IChangeLog changeLog)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
AbstractTripleStore |
LexiconRelation.getContainer()
Strengthens the return type.
|
Constructor and Description |
---|
LexiconRelation(AbstractTripleStore container,
IIndexManager indexManager,
String namespace,
Long timestamp,
Properties properties) |
Modifier and Type | Field and Description |
---|---|
protected AbstractTripleStore |
AbstractRDFTaskFactory.db
The database on which the data will be written.
|
Constructor and Description |
---|
AbstractRDFTaskFactory(AbstractTripleStore db,
RDFParserOptions parserOptions,
boolean deleteAfter,
org.openrdf.rio.RDFFormat fallback,
IStatementBufferFactory bufferFactory) |
LoadStatementBufferFactory(AbstractTripleStore db,
int bufferCapacity) |
RDFLoadTaskFactory(AbstractTripleStore db,
int bufferCapacity,
RDFParserOptions parserOptions,
boolean deleteafter,
org.openrdf.rio.RDFFormat fallback) |
RDFLoadTaskFactory(AbstractTripleStore db,
RDFParserOptions parserOptions,
boolean deleteafter,
org.openrdf.rio.RDFFormat fallback,
IStatementBufferFactory factory) |
RDFVerifyTaskFactory(AbstractTripleStore db,
int bufferCapacity,
RDFParserOptions parserOptions,
boolean deleteAfter,
org.openrdf.rio.RDFFormat fallback) |
VerifyStatementBuffer(AbstractTripleStore database,
int capacity,
AtomicLong nterms,
AtomicLong ntermsNotFound,
AtomicLong ntriples,
AtomicLong ntriplesNotFound) |
VerifyStatementBufferFactory(AbstractTripleStore db,
int bufferCapacity) |
Modifier and Type | Field and Description |
---|---|
protected AbstractTripleStore |
StatementBuffer.database
The database that will be used to resolve terms.
|
Modifier and Type | Method and Description |
---|---|
AbstractTripleStore |
IStatementBuffer.getDatabase()
The database that will be used to resolve terms.
|
AbstractTripleStore |
StatementBuffer.getDatabase()
The database that will be used to resolve terms.
|
AbstractTripleStore |
AbstractStatementBuffer.getDatabase()
The database from the ctor.
|
AbstractTripleStore |
AsynchronousStatementBufferFactory.AsynchronousStatementBufferImpl.getDatabase() |
AbstractTripleStore |
IStatementBuffer.getStatementStore()
The optional store into which statements will be inserted when non-
null . |
AbstractTripleStore |
StatementBuffer.getStatementStore()
The optional store into which statements will be inserted when non-
null . |
AbstractTripleStore |
AbstractStatementBuffer.getStatementStore()
Note: Returns the same value as
AbstractStatementBuffer.getDatabase() since the
distinction is not captured by this class. |
AbstractTripleStore |
AbstractStatementBuffer.StatementBuffer2.getStatementStore()
From the ctor.
|
AbstractTripleStore |
AsynchronousStatementBufferFactory.AsynchronousStatementBufferImpl.getStatementStore()
Returns
null . |
protected AbstractTripleStore |
TestLoadAndVerify.getStore()
Note: This allows an override of the properties that effect the data
load, in particular whether or not the full text index and statement
identifiers are maintained.
|
Modifier and Type | Method and Description |
---|---|
protected void |
TestAsynchronousStatementBufferFactory.doLoad(AbstractTripleStore store,
String resource,
boolean parallel)
Load using
AsynchronousStatementBufferWithoutSids2 . |
protected abstract void |
AbstractRIOTestCase.doLoad(AbstractTripleStore store,
String resource,
boolean parallel)
Implementation must load the data.
|
protected void |
TestLoadAndVerify.doLoad(AbstractTripleStore store,
String resource,
boolean parallel) |
protected void |
AbstractRIOTestCase.doLoad(AbstractTripleStore store,
String resource,
boolean parallel,
IStatementBufferFactory<BigdataStatement> factory)
Load the classpath resource or file / directory.
|
protected AsynchronousStatementBufferFactory<BigdataStatement,File> |
TestAsynchronousStatementBufferFactory.doLoad2(AbstractTripleStore store,
File resource,
boolean parallel)
Load using
AsynchronousStatementBufferFactory . |
protected void |
AbstractRIOTestCase.doVerify(AbstractTripleStore store,
String resource,
boolean parallel)
Verify the KB contains all explicit statements read from the resource.
|
protected List<Callable<Void>> |
AbstractRIOTestCase.getVerifyTasks(String resource,
AbstractTripleStore store)
Return a list of tasks which will verify the statements contained in the
specified classpath resource, file, or directory (recursive) against the
KB.
|
Constructor and Description |
---|
AbstractStatementBuffer.StatementBuffer2(AbstractTripleStore lexiconStore,
AbstractTripleStore statementStore,
boolean readOnly,
int capacity) |
AbstractStatementBuffer.StatementBuffer2(AbstractTripleStore lexiconStore,
boolean readOnly,
int capacity) |
AbstractStatementBuffer(AbstractTripleStore db,
boolean readOnly,
int capacity) |
StatementBuffer(AbstractTripleStore database,
int capacity)
Create a buffer that converts Sesame
Value objects to SPO
s and writes on the database when it is StatementBuffer.flush() ed. |
StatementBuffer(AbstractTripleStore database,
int capacity,
int queueCapacity) |
StatementBuffer(TempTripleStore statementStore,
AbstractTripleStore database,
int capacity,
int queueCapacity)
Create a buffer that writes on a
TempTripleStore when it is
StatementBuffer.flush() ed. |
Modifier and Type | Field and Description |
---|---|
AbstractTripleStore |
InferenceEngine.database
The database whose closure is being maintained.
|
protected AbstractTripleStore |
BaseClosure.db
The database whose configuration will determine which entailments are
to be maintained and which of those entailments are computed by
forward closure vs backchained.
|
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractRuleTestCase.applyRule(AbstractTripleStore db,
IRule rule,
IElementFilter<ISPO> filter,
long expectedSolutionCount,
long expectedMutationCount)
Applies the rule, copies the new entailments into the store and checks
the expected #of inferences computed and new statements copied into the
store.
|
protected void |
AbstractRuleTestCase.applyRule(AbstractTripleStore db,
IRule rule,
long expectedSolutionCount,
long expectedMutationCount) |
protected void |
TestTruthMaintenance.assertSameGraphs(TempTripleStore expected,
AbstractTripleStore actual)
This is a specialized test for equality in the graphs that simply compare
scans on the SPO index.
|
ClosureStats |
InferenceEngine.computeClosure(AbstractTripleStore focusStore)
Compute the forward closure of a focusStore against the database using
the algorithm selected by
AbstractTripleStore.Options#CLOSURE_CLASS . |
ClosureStats |
InferenceEngine.computeClosure(AbstractTripleStore focusStore,
boolean justify)
This variant allows you to explicitly NOT generate
Justification s
for the computed entailments. |
protected void |
TestDatabaseAtOnceClosure.doFixedPointTest(String[] resources,
AbstractTripleStore closureStore)
Compares ground truth for the closure of the source RDF/XML file(s) (as
computed by Sesame 2) against the closure as computed by bigdata.
|
protected IRule |
TestSlice.newRule(AbstractTripleStore store,
ISlice slice,
BigdataValue foo,
BigdataValue bar)
Creates a new rule instance for
TestSlice.test_slice() . |
SPO[] |
TestTruthMaintenance.selectRandomExplicitStatements(AbstractTripleStore db,
int N)
Select N explicit statements from the graph at random.
|
Constructor and Description |
---|
BackchainAccessPath(AbstractTripleStore database,
IAccessPath<ISPO> accessPath) |
BackchainAccessPath(AbstractTripleStore database,
IAccessPath<ISPO> accessPath,
Boolean isOwlSameAsUsed) |
BaseClosure(AbstractTripleStore db) |
FastClosure(AbstractTripleStore db) |
FullClosure(AbstractTripleStore db) |
InferenceEngine(AbstractTripleStore database)
Configure
InferenceEngine using the properties used to configure
the database. |
Modifier and Type | Field and Description |
---|---|
protected AbstractTripleStore |
RDRHistory.database
The database.
|
Modifier and Type | Method and Description |
---|---|
AbstractTripleStore |
BigdataSailTupleQuery.getTripleStore() |
AbstractTripleStore |
BigdataSailGraphQuery.getTripleStore() |
AbstractTripleStore |
BigdataSailBooleanQuery.getTripleStore() |
AbstractTripleStore |
BigdataSail.BigdataSailConnection.getTripleStore()
The implementation object.
|
AbstractTripleStore |
BigdataSailOperation.getTripleStore()
The backing database view.
|
AbstractTripleStore |
BigdataSailUpdate.getTripleStore() |
AbstractTripleStore |
BigdataSailRepositoryConnection.getTripleStore()
Return the backing
AbstractTripleStore object. |
Constructor and Description |
---|
BigdataSail(AbstractTripleStore database)
Constructor used to wrap an existing
AbstractTripleStore
instance. |
BigdataSail(AbstractTripleStore database,
IIndexManager mainIndexManager)
Core ctor.
|
BigdataValueReplacer(AbstractTripleStore database) |
RDRHistory(AbstractTripleStore database) |
TestRDRHistory.CustomRDRHistory(AbstractTripleStore database) |
Modifier and Type | Field and Description |
---|---|
AbstractTripleStore |
NanoSparqlClient.QueryOptions.tmpKb
Temp KB provided to the parser.
|
Modifier and Type | Method and Description |
---|---|
protected AbstractTripleStore |
Bigdata2ASTSPARQLSyntaxTest.getStore(Properties properties) |
protected AbstractTripleStore |
Bigdata2ASTSPARQL11SyntaxTest.getStore(Properties properties) |
Modifier and Type | Field and Description |
---|---|
protected AbstractTripleStore |
SD.tripleStore
The KB instance that is being described (from the constructor).
|
Modifier and Type | Method and Description |
---|---|
AbstractTripleStore |
BigdataRDFContext.getTripleStore(String namespace,
long timestamp)
Return a read-only view of the
AbstractTripleStore for the given
namespace will read from the commit point associated with the given
timestamp. |
Modifier and Type | Method and Description |
---|---|
protected static VoID.IVCount[] |
VoID.classUsage(AbstractTripleStore kb)
Return an efficient statistical summary for the class partitions.
|
protected static VoID.IVCount[] |
VoID.classUsage(AbstractTripleStore kb,
IV<?,?> civ,
VoID.IVCount[] classPartitionCounts)
Return the class partition statistics for the named graph.
|
boolean |
IFeatureSupported.isSupported(AbstractTripleStore tripleStore) |
protected static VoID.IVCount[] |
VoID.predicateUsage(AbstractTripleStore kb)
Return an array of the distinct predicates in the KB ordered by their
descending frequency of use.
|
protected static VoID.IVCount[] |
VoID.predicateUsage(AbstractTripleStore kb,
IV<?,?> civ,
VoID.IVCount[] predicatePartitionCounts)
Return the predicate partition statistics for the named graph.
|
Constructor and Description |
---|
SD(org.openrdf.model.Graph g,
AbstractTripleStore tripleStore,
String... serviceURI) |
VoID(org.openrdf.model.Graph g,
AbstractTripleStore tripleStore,
String[] serviceURI,
org.openrdf.model.Resource aDataset) |
Modifier and Type | Field and Description |
---|---|
protected AbstractTripleStore |
AbstractBigdataExprBuilderTestCase.tripleStore |
Modifier and Type | Method and Description |
---|---|
protected AbstractTripleStore |
AbstractBigdataExprBuilderTestCase.getStore(Properties properties) |
Modifier and Type | Field and Description |
---|---|
protected AbstractTripleStore |
AbstractASTEvaluationTestCase.store |
Modifier and Type | Method and Description |
---|---|
protected AbstractTripleStore |
AbstractASTEvaluationTestCase.getStore(Properties properties) |
Constructor and Description |
---|
BSBMQ5Setup(AbstractTripleStore store) |
Modifier and Type | Field and Description |
---|---|
protected AbstractTripleStore |
AST2BOpContext.db
The KB instance.
|
Modifier and Type | Method and Description |
---|---|
AbstractTripleStore |
IEvaluationContext.getAbstractTripleStore()
Return the database.
|
AbstractTripleStore |
AST2BOpContext.getAbstractTripleStore() |
protected AbstractTripleStore |
AbstractDataAndSPARQLTestCase.AbsHelper.getTripleStore() |
AbstractTripleStore |
AbstractDataDrivenSPARQLTestCase.TestHelper.getTripleStore() |
AbstractTripleStore |
AbstractDataDrivenSPARQLTestCase.UpdateTestHelper.getTripleStore() |
Modifier and Type | Method and Description |
---|---|
static boolean |
ASTEvalHelper.evaluateBooleanQuery(AbstractTripleStore store,
ASTContainer astContainer,
org.openrdf.query.BindingSet globallyScopedBS,
org.openrdf.query.Dataset dataset)
Evaluate a boolean query.
|
static org.openrdf.query.GraphQueryResult |
ASTEvalHelper.evaluateGraphQuery(AbstractTripleStore store,
ASTContainer astContainer,
org.openrdf.query.algebra.evaluation.QueryBindingSet globallyScopedBS,
org.openrdf.query.Dataset dataset)
Evaluate a CONSTRUCT/DESCRIBE query.
|
static org.openrdf.query.TupleQueryResult |
ASTEvalHelper.evaluateTupleQuery(AbstractTripleStore store,
ASTContainer astContainer,
org.openrdf.query.algebra.evaluation.QueryBindingSet globallyScopedBS,
org.openrdf.query.Dataset dataset)
Evaluate a SELECT query.
|
static ICloseableIterator<IBindingSet[]> |
ASTEvalHelper.evaluateTupleQuery2(AbstractTripleStore store,
ASTContainer astContainer,
org.openrdf.query.algebra.evaluation.QueryBindingSet globallyScopedBS,
boolean materialize)
Evaluate a SELECT query without converting the results into openrdf
solutions.
|
protected IDescribeCache |
TestDescribe.getDescribeCache(ASTContainer astContainer,
AbstractTripleStore store)
Return the
IDescribeCache iff it is enabled. |
static com.bigdata.rdf.sparql.ast.eval.ASTDeferredIVResolution.DeferredResolutionResult |
ASTDeferredIVResolution.resolveQuery(AbstractTripleStore store,
ASTContainer ast)
Do deferred resolution of IVs, which were left unresolved while preparing
the query
|
static com.bigdata.rdf.sparql.ast.eval.ASTDeferredIVResolution.DeferredResolutionResult |
ASTDeferredIVResolution.resolveQuery(AbstractTripleStore store,
ASTContainer ast,
org.openrdf.query.BindingSet bs,
org.openrdf.query.Dataset dataset,
AST2BOpContext ctxIn)
Do deferred resolution of IVs, which were left unresolved while preparing
the query
|
static com.bigdata.rdf.sparql.ast.eval.ASTDeferredIVResolution.DeferredResolutionResult |
ASTDeferredIVResolution.resolveUpdate(AbstractTripleStore store,
ASTContainer ast)
Do deferred resolution of IVs, which were left unresolved while preparing the update
|
static com.bigdata.rdf.sparql.ast.eval.ASTDeferredIVResolution.DeferredResolutionResult |
ASTDeferredIVResolution.resolveUpdate(AbstractTripleStore store,
ASTContainer ast,
org.openrdf.query.BindingSet bs,
org.openrdf.query.Dataset dataset)
Do deferred resolution of IVs, which were left unresolved while preparing the update
|
static com.bigdata.rdf.sparql.ast.eval.ASTDeferredIVResolution.DeferredResolutionResult |
ASTDeferredIVResolution.resolveUpdate(AbstractTripleStore store,
Update update,
org.openrdf.query.BindingSet bs,
org.openrdf.query.Dataset dataset)
Do deferred resolution of IVs, which were left unresolved after execution of each Update in UpdateRoot
|
Constructor and Description |
---|
AST2BOpContext(ASTContainer astContainer,
AbstractTripleStore db) |
ASTConstructIterator(AST2BOpContext context,
AbstractTripleStore tripleStore,
ConstructNode construct,
GraphPatternGroup<?> whereClause,
Map<String,BigdataBNode> bnodesIn,
info.aduna.iteration.CloseableIteration<org.openrdf.query.BindingSet,org.openrdf.query.QueryEvaluationException> src) |
CBD(AbstractTripleStore store,
DescribeModeEnum describeMode,
int describeIterationLimit,
int describeStatementLimit,
Map<String,BigdataBNode> bnodes) |
GeoSpatialServiceFactory.GeoSpatialInputBindingsIterator(IBindingSet[] bindingSet,
GeoSpatialServiceFactory.GeoSpatialServiceCallConfiguration gssConfig,
AbstractTripleStore kb,
com.bigdata.rdf.sparql.ast.eval.GeoSpatialServiceFactory.GeoSpatialServiceCall serviceCall) |
Modifier and Type | Method and Description |
---|---|
AbstractTripleStore |
ServiceCallCreateParams.getTripleStore()
The
AbstractTripleStore against which the query is being
evaluated. |
Modifier and Type | Method and Description |
---|---|
static IBindingSet[] |
ServiceCallUtility.resolve(AbstractTripleStore db,
org.openrdf.query.BindingSet[] serviceResults)
Batch resolve BigdataValues to IVs.
|
ServiceCall<? extends Object> |
ServiceRegistry.toServiceCall(AbstractTripleStore store,
org.eclipse.jetty.client.HttpClient cm,
org.openrdf.model.URI serviceURI,
ServiceNode serviceNode,
BaseJoinStats stats)
Resolve a
ServiceCall for a service URI . |
Modifier and Type | Method and Description |
---|---|
AbstractTripleStore |
SPORelation.getContainer()
Strengthened return type.
|
Constructor and Description |
---|
JustificationWriter(AbstractTripleStore dst,
IChunkedIterator<Justification> src,
AtomicLong nwritten) |
SPOArrayIterator(AbstractTripleStore db,
IAccessPath<ISPO> accessPath,
int limit,
IElementFilter<ISPO> filter)
Deprecated.
Fully buffers all statements selected by the
IAccessPath . |
SPORelation(AbstractTripleStore container,
IIndexManager indexManager,
String namespace,
Long timestamp,
Properties properties) |
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 | Class and Description |
---|---|
class |
AbstractLocalTripleStore
Abstract base class for both transient and persistent
ITripleStore
implementations using local storage. |
class |
LocalTripleStore
A triple store based on the bigdata architecture.
|
class |
ScaleOutTripleStore
Implementation of an
ITripleStore as a client of an
IBigdataFederation . |
class |
TempTripleStore
A temporary triple store based on the bigdata architecture.
|
Modifier and Type | Method and Description |
---|---|
AbstractTripleStore |
DataLoader.getDatabase()
The target database.
|
protected AbstractTripleStore |
ProxyTestCase.getStore()
Create a triple store instance using the delegate and using the
properties as configured by the delegate.
|
protected AbstractTripleStore |
TestLocalTripleStoreWithoutInlining.getStore(Properties properties) |
protected AbstractTripleStore |
TestTempTripleStore.getStore(Properties properties) |
protected abstract AbstractTripleStore |
AbstractTestCase.getStore(Properties properties) |
protected AbstractTripleStore |
TestLocalQuadStore.getStore(Properties properties) |
protected AbstractTripleStore |
ProxyTestCase.getStore(Properties properties)
Create a triple store instance using the delegate using the specified
properties (typically overriding one or more properties).
|
protected AbstractTripleStore |
TestLocalTripleStore.getStore(Properties properties) |
protected AbstractTripleStore |
TestLocalTripleStoreWithoutStatementIdentifiers.getStore(Properties properties) |
protected AbstractTripleStore |
TestScaleOutTripleStoreWithEmbeddedFederation.getStore(Properties properties) |
AbstractTripleStore |
AbstractTripleStore.init() |
protected AbstractTripleStore |
TestLocalTripleStoreWithoutInlining.reopenStore(AbstractTripleStore store)
Re-open the same backing store.
|
protected AbstractTripleStore |
TestTempTripleStore.reopenStore(AbstractTripleStore store)
Re-open the same backing store.
|
protected abstract AbstractTripleStore |
AbstractTestCase.reopenStore(AbstractTripleStore store) |
protected AbstractTripleStore |
TestLocalQuadStore.reopenStore(AbstractTripleStore store)
Re-open the same backing store.
|
protected AbstractTripleStore |
ProxyTestCase.reopenStore(AbstractTripleStore store)
Close and then re-open the triple store.
|
protected AbstractTripleStore |
TestLocalTripleStore.reopenStore(AbstractTripleStore store)
Re-open the same backing store.
|
protected AbstractTripleStore |
TestLocalTripleStoreWithoutStatementIdentifiers.reopenStore(AbstractTripleStore store)
Re-open the same backing store.
|
protected AbstractTripleStore |
TestScaleOutTripleStoreWithEmbeddedFederation.reopenStore(AbstractTripleStore store)
Re-open the same backing store.
|
Modifier and Type | Method and Description |
---|---|
long |
AbstractTripleStore.addStatements(AbstractTripleStore statementStore,
boolean copyOnly,
IChunkedOrderedIterator<ISPO> itr,
IElementFilter<ISPO> filter)
Add statements to the statementStore.
|
static void |
AbstractTestCase.assertLexiconIndicesConsistent(AbstractTripleStore store)
Verify that TERM2ID and ID2TERM have the same range count and that
all ID2TERM entries resolve a TERM2ID entry and that each TERM2ID
entry leads to an ID2TERM entry.
|
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. |
static void |
AbstractTestCase.assertStatementIndicesConsistent(AbstractTripleStore db,
int maxerrors)
Validates that the same statements are found in each of the statement
indices.
|
static TempTripleStore |
TripleStoreUtility.bulkExport(AbstractTripleStore db)
Exports all statements found in the data and all backchained entailments
for the db into a
TempTripleStore . |
long |
AbstractTripleStore.copyStatements(AbstractTripleStore dst,
IElementFilter<ISPO> filter,
boolean copyJustifications)
Copies the statements from this store into the specified store
using the same term identifiers (the lexicon is neither
copied to nor asserted on the target).
|
long |
AbstractTripleStore.copyStatements(AbstractTripleStore dst,
IElementFilter<ISPO> filter,
boolean copyJustifications,
IChangeLog changeLog) |
protected void |
TestTripleStore.doAddTermTest(AbstractTripleStore store,
org.openrdf.model.Value term)
Test helper verifies that the term is not in the lexicon, adds the term
to the lexicon, verifies that the term can be looked up by its assigned
term identifier, verifies that the term is now in the lexicon, and
verifies that adding the term again returns the same term identifier.
|
StringBuilder |
AbstractTripleStore.dumpStore(AbstractTripleStore resolveTerms,
boolean explicit,
boolean inferred,
boolean axioms) |
StringBuilder |
AbstractTripleStore.dumpStore(AbstractTripleStore resolveTerms,
boolean explicit,
boolean inferred,
boolean axioms,
boolean justifications)
Dumps the store in a human readable format (not suitable for
interchange).
|
StringBuilder |
AbstractTripleStore.dumpStore(AbstractTripleStore resolveTerms,
boolean explicit,
boolean inferred,
boolean axioms,
boolean history,
boolean justifications) |
StringBuilder |
AbstractTripleStore.dumpStore(AbstractTripleStore resolveTerms,
boolean explicit,
boolean inferred,
boolean axioms,
boolean history,
boolean justifications,
boolean sids,
IKeyOrder<ISPO> keyOrder)
Dumps the store in a human readable format (not suitable for
interchange).
|
static void |
AbstractTripleStore.fixPointStatementIdentifiers(AbstractTripleStore db,
AbstractTripleStore tempStore)
Computes the fixed point of those statements in the database which make
assertions about statement identifiers in the tmp store.
|
void |
DataLoader.logCounters(AbstractTripleStore database)
Report out a variety of interesting information on stdout and the
DataLoader.log . |
static boolean |
TripleStoreUtility.modelsEqual(AbstractTripleStore expected,
AbstractTripleStore actual)
Compares two RDF graphs for equality (same statements).
|
static ICloseableIterator<BigdataStatement> |
TripleStoreUtility.notFoundInTarget(AbstractTripleStore expected,
AbstractTripleStore actual)
Visits expected
BigdataStatement s not found in actual. |
protected AbstractTripleStore |
TestLocalTripleStoreWithoutInlining.reopenStore(AbstractTripleStore store)
Re-open the same backing store.
|
protected AbstractTripleStore |
TestTempTripleStore.reopenStore(AbstractTripleStore store)
Re-open the same backing store.
|
protected abstract AbstractTripleStore |
AbstractTestCase.reopenStore(AbstractTripleStore store) |
protected AbstractTripleStore |
TestLocalQuadStore.reopenStore(AbstractTripleStore store)
Re-open the same backing store.
|
protected AbstractTripleStore |
ProxyTestCase.reopenStore(AbstractTripleStore store)
Close and then re-open the triple store.
|
protected AbstractTripleStore |
TestLocalTripleStore.reopenStore(AbstractTripleStore store)
Re-open the same backing store.
|
protected AbstractTripleStore |
TestLocalTripleStoreWithoutStatementIdentifiers.reopenStore(AbstractTripleStore store)
Re-open the same backing store.
|
protected AbstractTripleStore |
TestScaleOutTripleStoreWithEmbeddedFederation.reopenStore(AbstractTripleStore store)
Re-open the same backing store.
|
Modifier and Type | Method and Description |
---|---|
static void |
DumpLexicon.dump(AbstractTripleStore store,
Writer w,
boolean showBlobs)
Dumps the lexicon in a variety of ways.
|
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.