Class DirectTypeHierarchyInferencer.DirectTypeHierarchyInferencerConnection
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.DirectTypeHierarchyInferencer.DirectTypeHierarchyInferencerConnection
- All Implemented Interfaces:
AutoCloseable, FederatedServiceResolverClient, ThreadSafetyAware, InferencerConnection, NotifyingSailConnection, SailConnection, SailConnectionListener
- Enclosing class:
DirectTypeHierarchyInferencer
private class DirectTypeHierarchyInferencer.DirectTypeHierarchyInferencerConnection
extends InferencerConnectionWrapper
implements SailConnectionListener
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate booleanFlag indicating whether an update of the inferred statements is needed. -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprivate voidprivate voidevaluateIntoStatements(ParsedGraphQuery query, Collection<Statement> statements) voidFlushes any pending updates to be processed and the resulting changes to be reported to registeredSailConnectionListeners.voidrollback()Rolls back the transaction, discarding any uncommitted changes that have been made in this SailConnection.voidNotifies the listener that a statement has been added in a transaction that it has registered itself with.voidNotifies the listener that a statement has been removed in a transaction that it has registered itself with.Methods inherited from class InferencerConnectionWrapper
addInferredStatement, clearInferred, commit, evaluate, flush, getContextIDs, getStatements, getWrappedConnection, hasStatement, prepare, removeInferredStatement, sizeMethods inherited from class NotifyingSailConnectionWrapper
addConnectionListener, removeConnectionListenerMethods inherited from class SailConnectionWrapper
addStatement, addStatement, begin, begin, clear, clearNamespaces, close, endUpdate, explain, getFederatedServiceResolver, getNamespace, getNamespaces, isActive, isOpen, pendingRemovals, prepareQuery, removeNamespace, removeStatement, removeStatements, setFederatedServiceResolver, setNamespace, setTransactionSettings, size, startUpdate, supportsConcurrentReadsMethods inherited from class Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface NotifyingSailConnection
addConnectionListener, removeConnectionListenerMethods inherited from interface SailConnection
addStatement, addStatement, begin, begin, clear, clearNamespaces, close, endUpdate, explain, getNamespace, getNamespaces, isActive, isOpen, pendingRemovals, prepareQuery, removeNamespace, removeStatement, removeStatements, setNamespace, setTransactionSettings, startUpdate
-
Field Details
-
updateNeeded
private boolean updateNeededFlag indicating whether an update of the inferred statements is needed.
-
-
Constructor Details
-
DirectTypeHierarchyInferencerConnection
-
-
Method Details
-
statementAdded
Description copied from interface:SailConnectionListenerNotifies the listener that a statement has been added in a transaction that it has registered itself with.- Specified by:
statementAddedin interfaceSailConnectionListener- Parameters:
st- The statement that was added.
-
statementRemoved
Description copied from interface:SailConnectionListenerNotifies the listener that a statement has been removed in a transaction that it has registered itself with.- Specified by:
statementRemovedin interfaceSailConnectionListener- Parameters:
st- The statement that was removed.
-
checkUpdatedStatement
-
rollback
Description copied from interface:SailConnectionRolls back the transaction, discarding any uncommitted changes that have been made in this SailConnection.- Specified by:
rollbackin interfaceSailConnection- Overrides:
rollbackin classSailConnectionWrapper- Throws:
SailException- If the SailConnection could not be rolled back.
-
flushUpdates
Description copied from interface:InferencerConnectionFlushes any pending updates to be processed and the resulting changes to be reported to registeredSailConnectionListeners.- Specified by:
flushUpdatesin interfaceInferencerConnection- Overrides:
flushUpdatesin classInferencerConnectionWrapper- Throws:
SailException- If the updates could not be processed.
-
evaluateIntoStatements
private void evaluateIntoStatements(ParsedGraphQuery query, Collection<Statement> statements) throws SailException, RDFHandlerException, QueryEvaluationException
-