public class FedX extends AbstractSail implements RepositoryResolverClient
For initialization of the federation and usage see FederationManager.
connectionTimeOut, DEFAULT_CONNECTION_TIMEOUT, DEFAULT_ITERATION_SYNC_THRESHOLD, initializationLock| Modifier and Type | Method and Description |
|---|---|
protected void |
addMember(Endpoint endpoint)
Add a member to the federation (internal).
|
protected SailConnection |
getConnectionInternal()
Returns a store-specific SailConnection object.
|
File |
getDataDir()
Gets the Sail's data directory.
|
List<Endpoint> |
getMembers() |
ValueFactory |
getValueFactory()
Gets a ValueFactory object that can be used to create IRI-, blank node-, literal- and statement objects.
|
WriteStrategy |
getWriteStrategy()
Compute and return the
WriteStrategy depending on the current federation configuration. |
protected void |
initializeInternal()
Do store-specific operations to initialize the store.
|
protected void |
initializeMember(Endpoint member) |
boolean |
isWritable()
Checks whether this Sail object is writable, i.e.
|
boolean |
removeMember(Endpoint endpoint)
Remove a member from the federation (internal)
|
void |
setDataDir(File dataDir)
Sets the data directory for the Sail.
|
void |
setFederationContext(FederationContext federationContext) |
void |
setRepositoryResolver(RepositoryResolver resolver) |
protected void |
shutDownInternal()
Try to shut down all federation members.
|
addSupportedIsolationLevel, connectionClosed, debugEnabled, getConnection, getDefaultIsolationLevel, getIterationCacheSyncThreshold, getSupportedIsolationLevels, init, initialize, isInitialized, isTrackResultSize, removeSupportedIsolationLevel, setConnectionTimeOut, setDefaultIsolationLevel, setIterationCacheSyncThreshold, setSupportedIsolationLevels, setSupportedIsolationLevels, setTrackResultSize, shutDown, toStringpublic void setFederationContext(FederationContext federationContext)
protected void addMember(Endpoint endpoint)
If the federation is already initialized, the given endpoint is explicitly initialized as well.
endpoint - public boolean removeMember(Endpoint endpoint)
endpoint - public WriteStrategy getWriteStrategy()
WriteStrategy depending on the current federation configuration.
The default implementation uses the RepositoryWriteStrategy with the first discovered writable
Endpoint. In none is found, the ReadOnlyWriteStrategy is used.WriteStrategyFedXRuntimeException - if the WriteStrategy could not be createdprotected SailConnection getConnectionInternal() throws SailException
AbstractSailgetConnectionInternal in class AbstractSailSailExceptionpublic File getDataDir()
SailgetDataDir in interface SailgetDataDir in class AbstractSailSail.setDataDir(File)public ValueFactory getValueFactory()
SailgetValueFactory in interface Sailprotected void initializeInternal()
throws SailException
AbstractSailinitializeInternal in class AbstractSailSailExceptionprotected void initializeMember(Endpoint member) throws SailException
SailExceptionpublic boolean isWritable()
throws SailException
SailisWritable in interface SailSailExceptionpublic void setDataDir(File dataDir)
Sailinitialized.setDataDir in interface SailsetDataDir in class AbstractSailprotected void shutDownInternal()
throws SailException
shutDownInternal in class AbstractSailFedXException - if not all members could be shut downSailExceptionpublic void setRepositoryResolver(RepositoryResolver resolver)
setRepositoryResolver in interface RepositoryResolverClientCopyright © 2015-2021 Eclipse Foundation. All Rights Reserved.