Interface NotifyingSail

All Superinterfaces:

Sail

All Known Implementing Classes:

AbstractForwardChainingInferencer, AbstractNotifyingSail, CustomGraphQueryInferencer, DedupingInferencer, DirectTypeHierarchyInferencer, ElasticsearchStore, ExtensibleStore, LmdbStore, LuceneSail, MemoryStore, NativeStore, NotifyingSailWrapper, SchemaCachingRDFSInferencer, ShaclSail

public interface NotifyingSail
extends Sail

An interface for Sails that notify registered SailChangedListeners of changes in the data in the Sail.

Author:

James Leigh

Method Summary

Modifier and Type	Method	Description
void	addSailChangedListener(SailChangedListener listener)	Adds the specified SailChangedListener to receive events when the data in this Sail object changes.
NotifyingSailConnection	getConnection()	Opens a connection on the Sail which can be used to query and update data.
void	removeSailChangedListener(SailChangedListener listener)	Removes the specified SailChangedListener so that it no longer receives events from this Sail object.

Methods inherited from interface Sail

getCollectionFactory, getDataDir, getDefaultIsolationLevel, getSupportedIsolationLevels, getValueFactory, init, isWritable, setDataDir, shutDown

Modifier and Type	Method	Description
default Supplier<CollectionFactory>	getCollectionFactory()	Gets a CollectionFactory that may be optimized for this store and may or may not use disk or other resources.
File	getDataDir()	Gets the Sail's data directory.
IsolationLevel	getDefaultIsolationLevel()	Retrieves the default IsolationLevel level on which transactions in this Sail operate.
List<IsolationLevel>	getSupportedIsolationLevels()	Retrieve the IsolationLevels supported by this SAIL, ordered by increasing complexity.
ValueFactory	getValueFactory()	Gets a ValueFactory object that can be used to create IRI-, blank node-, literal- and statement objects.
void	init()	Initializes the Sail.
boolean	isWritable()	Checks whether this Sail object is writable, i.e. if the data contained in this Sail object can be changed.
void	setDataDir(File dataDir)	Sets the data directory for the Sail.
void	shutDown()	Shuts down the Sail, giving it the opportunity to synchronize any stale data.

Method Details

getConnection

NotifyingSailConnection getConnection()
                               throws SailException

Opens a connection on the Sail which can be used to query and update data. Depending on how the implementation handles concurrent access, a call to this method might block when there is another open connection on this Sail.

Specified by:

getConnection in interface Sail

Throws:

SailException - If no transaction could be started, for example because the Sail is not writable.

addSailChangedListener

void addSailChangedListener(SailChangedListener listener)

Adds the specified SailChangedListener to receive events when the data in this Sail object changes.

removeSailChangedListener

void removeSailChangedListener(SailChangedListener listener)

Removes the specified SailChangedListener so that it no longer receives events from this Sail object.