Class AbstractForwardChainingInferencerConnection
java.lang.Object
org.eclipse.rdf4j.sail.helpers.SailConnectionWrapper
org.eclipse.rdf4j.sail.helpers.NotifyingSailConnectionWrapper
org.eclipse.rdf4j.sail.inferencer.InferencerConnectionWrapper
org.eclipse.rdf4j.sail.inferencer.fc.AbstractForwardChainingInferencerConnection
- All Implemented Interfaces:
AutoCloseable
,FederatedServiceResolverClient
,ThreadSafetyAware
,InferencerConnection
,NotifyingSailConnection
,SailConnection
,SailConnectionListener
public abstract class AbstractForwardChainingInferencerConnection
extends InferencerConnectionWrapper
implements SailConnectionListener
-
Field Summary
-
Constructor Summary
ConstructorDescription -
Method Summary
Modifier and TypeMethodDescriptionprotected abstract void
Adds all basic set of axiom statements from which the complete set can be inferred to the underlying Sail.protected abstract int
applyRules
(Model iteration) Returns the number of newly inferred statements.void
begin()
Begins a transaction requiringSailConnection.commit()
orSailConnection.rollback()
to be called to close the transaction.void
begin
(IsolationLevel level) Begins a transaction with the specifiedIsolationLevel
level, requiringSailConnection.commit()
orSailConnection.rollback()
to be called to close the transaction.protected abstract Model
protected void
void
Flushes any pending updates to be processed and the resulting changes to be reported to registeredSailConnectionListener
s.protected boolean
protected boolean
Indicates if a full recomputation of the deductive closure is needed.protected Model
void
rollback()
Rolls back the transaction, discarding any uncommitted changes that have been made in this SailConnection.void
Notifies the listener that a statement has been added in a transaction that it has registered itself with.void
Notifies the listener that a statement has been removed in a transaction that it has registered itself with.Methods inherited from class org.eclipse.rdf4j.sail.inferencer.InferencerConnectionWrapper
addInferredStatement, clearInferred, commit, evaluate, flush, getContextIDs, getStatements, getWrappedConnection, hasStatement, prepare, removeInferredStatement, size
Methods inherited from class org.eclipse.rdf4j.sail.helpers.NotifyingSailConnectionWrapper
addConnectionListener, removeConnectionListener
Methods inherited from class org.eclipse.rdf4j.sail.helpers.SailConnectionWrapper
addStatement, addStatement, clear, clearNamespaces, close, endUpdate, explain, getComparator, getFederatedServiceResolver, getNamespace, getNamespaces, getStatements, getSupportedOrders, isActive, isOpen, prepareQuery, removeNamespace, removeStatement, removeStatements, setFederatedServiceResolver, setNamespace, setTransactionSettings, size, startUpdate, supportsConcurrentReads
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.eclipse.rdf4j.sail.NotifyingSailConnection
addConnectionListener, removeConnectionListener
Methods inherited from interface org.eclipse.rdf4j.sail.SailConnection
addStatement, addStatement, clear, clearNamespaces, close, endUpdate, explain, getComparator, getNamespace, getNamespaces, getStatements, getSupportedOrders, isActive, isOpen, prepareQuery, removeNamespace, removeStatement, removeStatements, setNamespace, setTransactionSettings, startUpdate
-
Field Details
-
totalInferred
protected int totalInferred
-
-
Constructor Details
-
AbstractForwardChainingInferencerConnection
-
-
Method Details
-
statementAdded
Description copied from interface:SailConnectionListener
Notifies the listener that a statement has been added in a transaction that it has registered itself with.- Specified by:
statementAdded
in interfaceSailConnectionListener
- Parameters:
st
- The statement that was added.
-
createModel
-
statementRemoved
Description copied from interface:SailConnectionListener
Notifies the listener that a statement has been removed in a transaction that it has registered itself with.- Specified by:
statementRemoved
in interfaceSailConnectionListener
- Parameters:
st
- The statement that was removed.
-
flushUpdates
Description copied from interface:InferencerConnection
Flushes any pending updates to be processed and the resulting changes to be reported to registeredSailConnectionListener
s.- Specified by:
flushUpdates
in interfaceInferencerConnection
- Overrides:
flushUpdates
in classInferencerConnectionWrapper
- Throws:
SailException
- If the updates could not be processed.
-
begin
Description copied from interface:SailConnection
Begins a transaction requiringSailConnection.commit()
orSailConnection.rollback()
to be called to close the transaction. The transaction will use the defaultIsolationLevel
level for the SAIL, as returned bySail.getDefaultIsolationLevel()
.- Specified by:
begin
in interfaceSailConnection
- Overrides:
begin
in classSailConnectionWrapper
- Throws:
SailException
- If the connection could not start a transaction or if a transaction is already active on this connection.
-
begin
Description copied from interface:SailConnection
Begins a transaction with the specifiedIsolationLevel
level, requiringSailConnection.commit()
orSailConnection.rollback()
to be called to close the transaction.- Specified by:
begin
in interfaceSailConnection
- Overrides:
begin
in classSailConnectionWrapper
- Parameters:
level
- the transaction isolation level on which this transaction operates.- Throws:
SailException
- If the connection could not start a transaction, if the supplied transaction isolation level is not supported, or if a transaction is already active on this connection.
-
rollback
Description copied from interface:SailConnection
Rolls back the transaction, discarding any uncommitted changes that have been made in this SailConnection.- Specified by:
rollback
in interfaceSailConnection
- Overrides:
rollback
in classSailConnectionWrapper
- Throws:
SailException
- If the SailConnection could not be rolled back.
-
addAxiomStatements
Adds all basic set of axiom statements from which the complete set can be inferred to the underlying Sail.- Throws:
SailException
-
doInferencing
- Throws:
SailException
-
applyRules
Returns the number of newly inferred statements.- Throws:
SailException
-
prepareIteration
-
hasNewStatements
protected boolean hasNewStatements() -
needsFullRecomputation
protected boolean needsFullRecomputation()Indicates if a full recomputation of the deductive closure is needed.
-