Class ObservingSailDataset

java.lang.Object

org.eclipse.rdf4j.sail.base.DelegatingSailDataset

org.eclipse.rdf4j.sail.base.ObservingSailDataset

All Implemented Interfaces:

AutoCloseable, SailClosable, SailDataset

class ObservingSailDataset
extends DelegatingSailDataset

A IsolationLevels.SERIALIZABLE SailDataset that tracks the observed statement patterns to an SailSink.observe(Resource, IRI, Value, Resource...) to check consistency.

Field Summary

Fields

Modifier and Type	Field	Description
private final SailSink	observer	The SailSink that is tracking the statement patterns.

Constructor Summary

Constructors

Constructor	Description
ObservingSailDataset(SailDataset delegate, SailSink observer)	Creates a IsolationLevels.SERIALIZABLE SailDataset that tracks consistency.

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.
CloseableIteration<? extends Resource, SailException>	getContextIDs()	Returns the set of all unique context identifiers that are used to store statements.
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.

Methods inherited from class DelegatingSailDataset

getNamespace, getNamespaces, getTriples, toString

Methods inherited from class Object

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

Field Details

observer

private final SailSink observer

The SailSink that is tracking the statement patterns.

Constructor Details

ObservingSailDataset

public ObservingSailDataset(SailDataset delegate,
 SailSink observer)

Creates a IsolationLevels.SERIALIZABLE SailDataset that tracks consistency.

Parameters:

delegate - to be SailDataset.close() when this SailDataset is closed.

observer - to be SailSink.flush() and SailClosable.close() when this SailDataset is closed.

Method Details

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

Overrides:

close in class DelegatingSailDataset

Throws:

SailException - if this resource cannot be closed

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

Overrides:

getContextIDs in class DelegatingSailDataset

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

Overrides:

getStatements in class DelegatingSailDataset

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.