Class UnionSailSource

java.lang.Object

org.eclipse.rdf4j.sail.base.UnionSailSource

All Implemented Interfaces:

AutoCloseable, SailClosable, SailSource

class UnionSailSource
extends Object
implements SailSource

Combines two sources to act as a single SailSource. This is useful to provide a combined view of both explicit and inferred statements.

Field Summary

Fields

Modifier and Type	Field	Description
private final SailSource	additional	Additional statements that should be included in SailDatasets.
private final SailSource	primary	The branch that will be used in calls to sink(IsolationLevel).

Constructor Summary

Constructors

Constructor	Description
UnionSailSource(SailSource primary, SailSource additional)	An SailSource that combines two other SailSourcees.

Method Summary

Modifier and Type	Method	Description
void	close()	Closes this resource, relinquishing any underlying resources.
SailDataset	dataset(IsolationLevel level)	Create an observable SailDataset of the current state of this SailSource.
void	flush()	Apply all the changes to this branch to the backing SailSource, if applicable.
SailSource	fork()	Creates a new branch of this source.
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.
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

primary

private final SailSource primary

The branch that will be used in calls to sink(IsolationLevel).

additional

private final SailSource additional

Additional statements that should be included in SailDatasets.

Constructor Details

UnionSailSource

public UnionSailSource(SailSource primary,
 SailSource additional)

An SailSource that combines two other SailSourcees.

Parameters:

primary - delegates all calls to the given SailSource.

additional - delegate all call except sink(IsolationLevel).

Method Details

toString

public String toString()

Overrides:

toString in class Object

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

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

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