Class SailDatasetImpl

java.lang.Object

org.eclipse.rdf4j.sail.base.SailDatasetImpl

All Implemented Interfaces:

AutoCloseable, SailClosable, SailDataset

class SailDatasetImpl
extends Object
implements SailDataset

A view of an SailSource that is derived from a backing SailDataset.

Field Summary

Fields

Modifier and Type	Field	Description
private final Changeset	changes	Changes that have not yet been SailSource.flush()ed to the backing SailDataset.
private final SailDataset	derivedFrom	SailDataset of the backing SailSource.
private static final EmptyIteration<Namespace, SailException>	NAMESPACES_EMPTY_ITERATION
private static final EmptyIteration<Statement, SailException>	STATEMENT_EMPTY_ITERATION
private static final EmptyIteration<Triple, SailException>	TRIPLE_EMPTY_ITERATION

Constructor Summary

Constructors

Constructor	Description
SailDatasetImpl(SailDataset derivedFrom, Changeset changes)	Create a derivative dataset that applies the given changeset.

Method Summary

Modifier and Type	Method	Description
void	close()	Called when this SailDataset is no longer is used, such as when a read operation is complete.
private CloseableIteration<? extends Statement, SailException>	difference(CloseableIteration<? extends Statement, SailException> result, Function<Statement, Boolean> excluded)
CloseableIteration<? extends Resource, SailException>	getContextIDs()	Returns the set of all unique context identifiers that are used to store statements.
String	getNamespace(String prefix)	Gets the namespace that is associated with the specified prefix, if any.
CloseableIteration<? extends Namespace, SailException>	getNamespaces()	Gets the namespaces relevant to the data contained in this object.
CloseableIteration<? extends Statement, SailException>	getStatements(Resource subj, IRI pred, Value obj, Resource... contexts)	Gets all statements that have a specific subject, predicate and/or object.
CloseableIteration<? extends Triple, SailException>	getTriples(Resource subj, IRI pred, Value obj)	Gets all RDF-star triples that have a specific subject, predicate and/or object.
private boolean	isDeprecated(Triple triple, List<Statement> deprecatedStatements)
String	toString()
private CloseableIteration<? extends Triple, SailException>	triplesDifference(CloseableIteration<? extends Triple, SailException> result, Function<Triple,Boolean> excluded)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

TRIPLE_EMPTY_ITERATION

private static final EmptyIteration<Triple, SailException> TRIPLE_EMPTY_ITERATION

NAMESPACES_EMPTY_ITERATION

private static final EmptyIteration<Namespace, SailException> NAMESPACES_EMPTY_ITERATION

STATEMENT_EMPTY_ITERATION

private static final EmptyIteration<Statement, SailException> STATEMENT_EMPTY_ITERATION

derivedFrom

private final SailDataset derivedFrom

SailDataset of the backing SailSource.

changes

private final Changeset changes

Changes that have not yet been SailSource.flush()ed to the backing SailDataset.

Constructor Details

SailDatasetImpl

public SailDatasetImpl(SailDataset derivedFrom,
 Changeset changes)

Create a derivative dataset that applies the given changeset. The life cycle of this and the given SailDataset are bound.

Parameters:

derivedFrom - will be released when this object is released

changes - changeset to be observed with the given dataset

Method Details

toString

public String toString()

Overrides:

toString in class Object

close

public void close()
           throws SailException

Description copied from interface: SailDataset

Called when this SailDataset is no longer is used, such as when a read operation is complete. An isolation level compatible with IsolationLevels.SNAPSHOT will ensure the state of this SailDataset dose not change between the first call to this object until

invalid reference

SailClosable#release()

is called.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface SailClosable

Specified by:

close in interface SailDataset

Throws:

SailException - if this resource cannot be closed

getNamespace

public String getNamespace(String prefix)
                    throws SailException

Description copied from interface: SailDataset

Gets the namespace that is associated with the specified prefix, if any.

Specified by:

getNamespace in interface SailDataset

Parameters:

prefix - A namespace prefix, or an empty string in case of the default namespace.

Returns:

The namespace name that is associated with the specified prefix, or null if there is no such namespace.

Throws:

SailException - If this object encountered an error or unexpected situation internally.

getNamespaces

public CloseableIteration<? extends Namespace, SailException> getNamespaces()
                                                                     throws SailException

Description copied from interface: SailDataset

Gets the namespaces relevant to the data contained in this object.

Specified by:

getNamespaces in interface SailDataset

Returns:

An iterator over the relevant namespaces, should not contain any duplicates.

Throws:

SailException - If this object encountered an error or unexpected situation internally.

getContextIDs

public CloseableIteration<? extends Resource, SailException> getContextIDs()
                                                                    throws SailException

Description copied from interface: SailDataset

Returns the set of all unique context identifiers that are used to store statements.

Specified by:

getContextIDs in interface SailDataset

Returns:

An iterator over the context identifiers, should not contain any duplicates.

Throws:

SailException

getStatements

public CloseableIteration<? extends Statement, SailException> getStatements(Resource subj,
 IRI pred,
 Value obj,
 Resource... contexts)
                                                                     throws SailException

Description copied from interface: SailDataset

Gets all statements that have a specific subject, predicate and/or object. All three parameters may be null to indicate wildcards. Optionally a (set of) context(s) may be specified in which case the result will be restricted to statements matching one or more of the specified contexts.

Specified by:

getStatements in interface SailDataset

Parameters:

subj - A Resource specifying the subject, or null for a wildcard.

pred - A IRI specifying the predicate, or null for a wildcard.

obj - A Value specifying the object, or null for a wildcard.

contexts - The context(s) to get the statements from. Note that this parameter is a vararg and as such is optional. If no contexts are supplied the method operates on all contexts.

Returns:

An iterator over the relevant statements.

Throws:

SailException - If the triple source failed to get the statements.

getTriples

public CloseableIteration<? extends Triple, SailException> getTriples(Resource subj,
 IRI pred,
 Value obj)
                                                               throws SailException

Description copied from interface: SailDataset

Gets all RDF-star triples that have a specific subject, predicate and/or object. All three parameters may be null to indicate wildcards.

Specified by:

getTriples in interface SailDataset

Parameters:

subj - A Resource specifying the subject, or null for a wildcard.

pred - A IRI specifying the predicate, or null for a wildcard.

obj - A Value specifying the object, or null for a wildcard.

Returns:

An iterator over the relevant triples.

Throws:

SailException - If the triple source failed to get the RDF-star triples.

difference

private CloseableIteration<? extends Statement, SailException> difference(CloseableIteration<? extends Statement, SailException> result,
 Function<Statement, Boolean> excluded)

triplesDifference

private CloseableIteration<? extends Triple, SailException> triplesDifference(CloseableIteration<? extends Triple, SailException> result,
 Function<Triple,Boolean> excluded)

isDeprecated

private boolean isDeprecated(Triple triple,
 List<Statement> deprecatedStatements)