Class SailSourceBranch

java.lang.Object

org.eclipse.rdf4j.sail.base.SailSourceBranch

All Implemented Interfaces:

AutoCloseable, SailClosable, SailSource

class SailSourceBranch
extends Object
implements SailSource

An SailSource that keeps a delta of its state from a backing SailSource.

Field Summary

Fields

Modifier and Type	Field	Description
private final boolean	autoFlush	If this SailSource should be flushed to the backing SailSource when it is not in use.
private final SailSource	backingSource	The underly SailSource this SailSource is derived from.
private final ArrayDeque<Changeset>	changes	The difference between this SailSource and the backing SailSource.
private static final org.slf4j.Logger	logger
private final ModelFactory	modelFactory	The Model instances that should be used to store SailSink.approve(Resource, IRI, Value, Resource) and SailSink.deprecate(Resource, IRI, Value, Resource) statements.
private final Collection<SailDataset>	observers	Set of open SailDataset for this SailSource.
private final Set<Changeset>	pending	SailSink that have been created, but not yet SailSink.flush()ed to this SailSource.
private SailSink	prepared	Non-null after prepare(), but before flush().
private final ReentrantLock	semaphore	Used to prevent changes to this object's field from multiple threads.
private SailSink	serializable	Non-null when in IsolationLevels.SERIALIZABLE (or higher) mode.
private SailDataset	snapshot	Non-null when in IsolationLevels.SNAPSHOT (or higher) mode.

Constructor Summary

Constructors

Constructor	Description
SailSourceBranch(SailSource backingSource)	Creates a new in-memory SailSource derived from the given SailSource.
SailSourceBranch(SailSource backingSource, ModelFactory modelFactory)	Creates a new SailSource derived from the given SailSource.
SailSourceBranch(SailSource backingSource, ModelFactory modelFactory, boolean autoFlush)	Creates a new SailSource derived from the given SailSource and if autoFlush is true, will automatically call flush() when not in use.

Method Summary

Modifier and Type	Method	Description
(package private) void	autoFlush()
void	close()	Closes this resource, relinquishing any underlying resources.
(package private) void	closeChangeset(Changeset changeset)
(package private) void	compressChanges()
SailDataset	dataset(IsolationLevel level)	Create an observable SailDataset of the current state of this SailSource.
private SailDataset	derivedFromSerializable(IsolationLevel level)
private SailDataset	derivedFromSnapshot(IsolationLevel level)
void	flush()	Apply all the changes to this branch to the backing SailSource, if applicable.
private void	flush(Changeset change, SailSink sink)
private void	flush(SailSink sink)
SailSource	fork()	Creates a new branch of this source.
boolean	isChanged()
private boolean	isChanged(Changeset change)
(package private) void	merge(Changeset change)
void	prepare()	Check the consistency of this branch and throws a SailConflictException if SailSource.flush()ing this branch would cause the backing SailSource to be inconsistent, if applicable.
private void	prepare(Changeset change, SailSink sink)
private void	prepare(SailSink sink)
(package private) void	preparedChangeset(Changeset changeset)
SailSink	sink(IsolationLevel level)	Create a SailSink that when when its SailSource.flush() is called, the changes are applied to this source.
String	toString()

Methods inherited from class Object

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

Field Details

logger

private static final org.slf4j.Logger logger

semaphore

private final ReentrantLock semaphore

Used to prevent changes to this object's field from multiple threads.

changes

private final ArrayDeque<Changeset> changes

The difference between this SailSource and the backing SailSource.

pending

private final Set<Changeset> pending

SailSink that have been created, but not yet SailSink.flush()ed to this SailSource.

observers

private final Collection<SailDataset> observers

Set of open SailDataset for this SailSource.

backingSource

private final SailSource backingSource

The underly SailSource this SailSource is derived from.

modelFactory

private final ModelFactory modelFactory

The Model instances that should be used to store SailSink.approve(Resource, IRI, Value, Resource) and SailSink.deprecate(Resource, IRI, Value, Resource) statements.

autoFlush

private final boolean autoFlush

If this SailSource should be flushed to the backing SailSource when it is not in use.

snapshot

private SailDataset snapshot

Non-null when in IsolationLevels.SNAPSHOT (or higher) mode.

serializable

private SailSink serializable

Non-null when in IsolationLevels.SERIALIZABLE (or higher) mode.

prepared

private SailSink prepared

Non-null after prepare(), but before flush().

Constructor Details

SailSourceBranch

public SailSourceBranch(SailSource backingSource)

Creates a new in-memory SailSource derived from the given SailSource.

Parameters:

backingSource -

SailSourceBranch

public SailSourceBranch(SailSource backingSource,
 ModelFactory modelFactory)

Creates a new SailSource derived from the given SailSource.

Parameters:

backingSource -

modelFactory -

SailSourceBranch

public SailSourceBranch(SailSource backingSource,
 ModelFactory modelFactory,
 boolean autoFlush)

Creates a new SailSource derived from the given SailSource and if autoFlush is true, will automatically call flush() when not in use.

Parameters:

backingSource -

modelFactory -

autoFlush -

Method Details

close

public void close()
           throws SailException

Description copied from interface: SailClosable

Closes this resource, relinquishing any underlying resources.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface SailClosable

Throws:

SailException - if this resource cannot be closed

sink

public SailSink sink(IsolationLevel level)
              throws SailException

Description copied from interface: SailSource

Create a SailSink that when when its SailSource.flush() is called, the changes are applied to this source.

Specified by:

sink in interface SailSource

Parameters:

level - If this level is compatible with IsolationLevels.SERIALIZABLE then a SailSink.prepare() can throw a SailConflictException.

Returns:

Newly created SailSink

Throws:

SailException

dataset

public SailDataset dataset(IsolationLevel level)
                    throws SailException

Description copied from interface: SailSource

Create an observable SailDataset of the current state of this SailSource. Repeatedly calling with methods with IsolationLevels.SNAPSHOT (or higher) isolation levels will result in SailDatasets that are all derived from the same state of the backing SailSource (if applicable), that is the only difference between the states of the SailDataset will be from changes using this SailSource.sink(IsolationLevel).

Specified by:

dataset in interface SailSource

Parameters:

level - If this is compatible with IsolationLevels.SNAPSHOT_READ the resulting SailDataset will observe a single state of this SailSource.

Returns:

an SailDataset of the current state

Throws:

SailException

fork

public SailSource fork()

Description copied from interface: SailSource

Creates a new branch of this source. When it's SailSource.flush() is called the changes are applied to this backing source.

Specified by:

fork in interface SailSource

Returns:

a branched SailSource.

prepare

public void prepare()
             throws SailException

Description copied from interface: SailSource

Check the consistency of this branch and throws a SailConflictException if SailSource.flush()ing this branch would cause the backing SailSource to be inconsistent, if applicable. If this is the final backing SailSource calling this method has no effect.

Specified by:

prepare in interface SailSource

Throws:

SailException

flush

public void flush()
           throws SailException

Description copied from interface: SailSource

Apply all the changes to this branch to the backing SailSource, if applicable. If this is the final backing SailSource calling this method has no effect.

Specified by:

flush in interface SailSource

Throws:

SailException

isChanged

public boolean isChanged()

toString

public String toString()

Overrides:

toString in class Object

preparedChangeset

void preparedChangeset(Changeset changeset)

merge

void merge(Changeset change)

compressChanges

void compressChanges()

closeChangeset

void closeChangeset(Changeset changeset)

autoFlush

void autoFlush()
        throws SailException

Throws:

SailException

isChanged

private boolean isChanged(Changeset change)

derivedFromSerializable

private SailDataset derivedFromSerializable(IsolationLevel level)
                                     throws SailException

Throws:

SailException

derivedFromSnapshot

private SailDataset derivedFromSnapshot(IsolationLevel level)
                                 throws SailException

Throws:

SailException

prepare

private void prepare(SailSink sink)
              throws SailException

Throws:

SailException

prepare

private void prepare(Changeset change,
 SailSink sink)
              throws SailException

Throws:

SailException

flush

private void flush(SailSink sink)
            throws SailException

Throws:

SailException

flush

private void flush(Changeset change,
 SailSink sink)
            throws SailException

Throws:

SailException