com.bigdata.rdf.store

Interface IRawTripleStore

All Superinterfaces:

ITripleStore

All Known Implementing Classes:

AbstractLocalTripleStore, AbstractTripleStore, LocalTripleStore, ScaleOutTripleStore, TempTripleStore

public interface IRawTripleStore
extends ITripleStore

Low-level API directly using long term identifiers rather than an RDF Value object model.

Version:

$Id$

Author:

Bryan Thompson

Field Summary

Fields

Modifier and Type	Field and Description
static String	NULLSTR The constant NULL.

Method Summary

Methods

Modifier and Type	Method and Description
long	addStatements(IChunkedOrderedIterator<ISPO> itr, IElementFilter<ISPO> filter) Deprecated. by SPORelation.insert(IChunkedOrderedIterator)
long	addStatements(ISPO[] stmts, int numStmts) Writes the statements onto the statements indices (batch, parallel, NO truth maintenance).
long	addStatements(ISPO[] stmts, int numStmts, IElementFilter<ISPO> filter) Writes the statements onto the statement indices (batch, parallel, NO truth maintenance).
IV	addTerm(org.openrdf.model.Value value) Add a term into the term:id index and the id:term index, returning the assigned term identifier (non-batch API).
void	addTerms(BigdataValue[] terms) Batch insert of terms into the database.
IChunkedOrderedIterator<ISPO>	bulkCompleteStatements(IChunkedOrderedIterator<ISPO> itr) This method fills out the statement metadata (type and sid) for ISPOs that are present in the database.
IChunkedOrderedIterator<ISPO>	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>	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).
IAccessPath<ISPO>	getAccessPath(IKeyOrder<ISPO> keyOrder) Deprecated. by SPORelation#getAccessPath(SPOKeyOrder, com.bigdata.relation.rule.IPredicate)
IAccessPath<ISPO>	getAccessPath(IV s, IV p, IV o) Deprecated. by SPORelation.getAccessPath(IV, IV, IV)
IV	getIV(org.openrdf.model.Value value) Deprecated. This is only used by the unit tests. It is not efficient for scale-out.
ISPO	getStatement(IV s, IV p, IV o) Deprecated. does not support quads.
ISPO	getStatement(IV s, IV p, IV o, IV c) Return the statement from the database (fully bound s:p:o only).
org.openrdf.model.Value	getTerm(IV iv) Return the RDF Value given an internal value (non-batch api).
long	removeStatements(IChunkedOrderedIterator<ISPO> itr) Removes the statements from the statement indices (batch, parallel, NO truth maintenance).
long	removeStatements(ISPO[] stmts, int numStmts) Removes the statements from the statement indices (batch, parallel, NO truth maintenance).
String	toString(IV iv) Externalizes a term using an abbreviated syntax.
String	toString(IV s, IV p, IV o) Deprecated. by toString(IV, IV, IV, IV)
String	toString(IV s, IV p, IV o, IV c) Externalizes a quad or a triple with a statement identifier using an abbreviated syntax.

Methods inherited from interface com.bigdata.rdf.store.ITripleStore

abort, addStatement, addStatement, asStatement, asStatementIterator, asValue, close, commit, destroy, getAccessPath, getAccessPath, getBNodeCount, getDataLoader, getInferenceEngine, getLiteralCount, getNamedGraphCount, getStatement, getStatement, getStatementCount, getStatementCount, getStatementCount, getStatementCount, getStatements, getStatements, getTermCount, getURICount, hasStatement, hasStatement, isQuads, isReadOnly, removeStatements, removeStatements

Field Detail

NULLSTR

static final String NULLSTR

The constant NULL.

See Also:

Constant Field Values

Method Detail

addTerm

IV addTerm(org.openrdf.model.Value value)

Add a term into the term:id index and the id:term index, returning the assigned term identifier (non-batch API).

Note: This method delegates to the batch API, but it is extremely inefficient for scale-out as it does one RMI per request!

Parameters:

value - The term.

Returns:

The assigned internal value.

addTerms

void addTerms(BigdataValue[] terms)

Batch insert of terms into the database. The internal values are set on the terms as a side-effect.

Parameters:

terms - An array to be inserted.

See Also:

LexiconRelation.addTerms(BigdataValue[], int, boolean)

getTerm

org.openrdf.model.Value getTerm(IV iv)

Return the RDF Value given an internal value (non-batch api).

Returns:

the RDF value or null if there is no term with that internal value in the index.

getIV

IV getIV(org.openrdf.model.Value value)

Deprecated. This is only used by the unit tests. It is not efficient for scale-out.

Return the pre-assigned internal value for the value (non-batch API).

Parameters:

value - Any Value reference (MAY be null).

Returns:

The pre-assigned internal value -or- null iff the term is not known to the database.

getAccessPath

IAccessPath<ISPO> getAccessPath(IV s,
                              IV p,
                              IV o)

Deprecated. by SPORelation.getAccessPath(IV, IV, IV)

Chooses and returns the best IAccessPath for the given triple pattern.

Parameters:

s - The internal value for the subject -or- null.

p - The internal value for the predicate -or- null.

o - The internal value for the object -or- null.

getAccessPath

IAccessPath<ISPO> getAccessPath(IKeyOrder<ISPO> keyOrder)

Deprecated. by SPORelation#getAccessPath(SPOKeyOrder, com.bigdata.relation.rule.IPredicate)

Return the IAccessPath for the specified IKeyOrder and a fully unbound triple pattern. This is generally used only when you want to perform a IAccessPath#distinctTermScan().

getStatement

ISPO getStatement(IV s,
                IV p,
                IV o,
                IV c)

Return the statement from the database (fully bound s:p:o only).

Note: This may be used to examine the StatementEnum.

Parameters:

s - The internal value (IV) for the subject.

p - The internal value (IV) for the predicate.

o - The internal value (IV) for the object.

c - The internal value (IV) for the context (required for quads and ignored for triples).

Returns:

The SPO for that statement, including its StatementEnum -or- null iff the statement is not in the database.

Throws:

IllegalArgumentException - if the s, p, or o is null.

IllegalArgumentException - if the c is null and ITripleStore.isQuads() would return true.

getStatement

ISPO getStatement(IV s,
                IV p,
                IV o)

Deprecated. does not support quads.

addStatements

long addStatements(ISPO[] stmts,
                 int numStmts)

Writes the statements onto the statements indices (batch, parallel, NO truth maintenance).

Parameters:

stmts - The statements (sorted into IKeyOrder#SPO order as a side-effect).

numStmts - The #of entries in stmts that are valid.

Returns:

The #of statements that were written on the indices (a statement that was previously an axiom or inferred and that is converted to an explicit statement by this method will be reported in this count as well as any statement that was not pre-existing in the database).

addStatements

long addStatements(ISPO[] stmts,
                 int numStmts,
                 IElementFilter<ISPO> filter)

Writes the statements onto the statement indices (batch, parallel, NO truth maintenance).

Parameters:

stmts - The statements.

numStmts - The #of entries in stmts that are valid.

filter - Optional statement filter. Statements matching the filter are NOT added to the database.

Returns:

The #of statements that were written on the indices (a statement that was previously an axiom or inferred and that is converted to an explicit statement by this method will be reported in this count as well as any statement that was not pre-existing in the database).

addStatements

long addStatements(IChunkedOrderedIterator<ISPO> itr,
                 IElementFilter<ISPO> filter)

Deprecated. by SPORelation.insert(IChunkedOrderedIterator)

Writes the statements onto the statement indices (batch, parallel, NO truth maintenance).

Parameters:

itr - An iterator visiting the statements to be added.

filter - Optional statement filter. Statements matching the filter are NOT added to the database. The iterator is closed by this operation.

Returns:

The #of statements that were written on the indices (a statement that was previously an axiom or inferred and that is converted to an explicit statement by this method will be reported in this count as well as any statement that was not pre-existing in the database).

removeStatements

long removeStatements(ISPO[] stmts,
                    int numStmts)

Removes the statements from the statement indices (batch, parallel, NO truth maintenance).

Note: The StatementEnum on the SPOs is ignored by this method. It will delete all statements having the same bindings regardless of whether they are inferred, explicit, or axioms.

Parameters:

itr - The iterator

Returns:

The #of statements that were removed from the indices.

removeStatements

long removeStatements(IChunkedOrderedIterator<ISPO> itr)

Removes the statements from the statement indices (batch, parallel, NO truth maintenance).

Note: The StatementEnum on the SPOs is ignored by this method. It will delete all statements having the same bindings regardless of whether they are inferred, explicit, or axioms.

Parameters:

itr - The iterator

Returns:

The #of statements that were removed from the indices.

bulkFilterStatements

IChunkedOrderedIterator<ISPO> 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).

Parameters:

stmts - the statements to test

numStmts - the number of statements to test

present - if true, filter for statements that exist in the db, otherwise filter for statements that do not exist

Returns:

an iteration over the filtered set of statements

bulkFilterStatements

IChunkedOrderedIterator<ISPO> 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).

Parameters:

itr - an iterator over the set of statements to test

present - if true, filter for statements that exist in the db, otherwise filter for statements that do not exist

Returns:

an iteration over the filtered set of statements

bulkCompleteStatements

IChunkedOrderedIterator<ISPO> bulkCompleteStatements(IChunkedOrderedIterator<ISPO> itr)

This method fills out the statement metadata (type and sid) for ISPOs that are present in the database. ISPOs not present in the database are left as-is.

Returns:

An iterator visiting the completed ISPOs. Any ISPOs that were not found will be present but their statement metadata (type and sid) will be unchanged.

toString

String toString(IV s,
              IV p,
              IV o,
              IV c)

Externalizes a quad or a triple with a statement identifier using an abbreviated syntax.

toString

String toString(IV s,
              IV p,
              IV o)

Deprecated. by toString(IV, IV, IV, IV)

Externalizes a triple using an abbreviated syntax.

toString

String toString(IV iv)

Externalizes a term using an abbreviated syntax.

Parameters:

iv - The term identifier.

Returns:

A representation of the term.