Modifier and Type | Field and Description |
---|---|
protected HashMap<String,Endpoint> |
EndpointManager.endpoints |
protected List<Endpoint> |
FedXFactory.members |
Modifier and Type | Method and Description |
---|---|
Endpoint |
EndpointManager.getEndpoint(String endpointID) |
Endpoint |
EndpointManager.getEndpointByName(String endpointName) |
Endpoint |
EndpointManager.getEndpointByUrl(String endpointUrl)
Return the Endpoint for the provided endpoint url, if it exists.
|
Modifier and Type | Method and Description |
---|---|
Collection<Endpoint> |
EndpointManager.getAvailableEndpoints() |
List<Endpoint> |
EndpointManager.getEndpoints(Set<String> endpointIDs) |
List<Endpoint> |
FedX.getMembers() |
Modifier and Type | Method and Description |
---|---|
void |
EndpointManager.addEndpoint(Endpoint e)
Add the (initialized) endpoint to this endpoint manager to be used by the
FederationManager . |
void |
FederationManager.addEndpoint(Endpoint e,
boolean... updateStrategy)
Add the specified endpoint to the federation.
|
protected void |
FedX.addMember(Endpoint endpoint)
Add a member to the federation (internal).
|
protected void |
FedX.initializeMember(Endpoint member) |
protected void |
EndpointManager.removeEndpoint(Endpoint e)
Remove the provided endpoint from this endpoint manager to be used by the
FederationManager . |
void |
FederationManager.removeEndpoint(Endpoint e,
boolean... updateStrategy)
Remove the specified endpoint from the federation.
|
boolean |
FedX.removeMember(Endpoint endpoint)
Remove a member from the federation (internal)
|
Modifier and Type | Method and Description |
---|---|
void |
FederationManager.addAll(List<Endpoint> endpoints)
Add the specified endpoints to the federation and take care for updating all structures.
|
static FedXRepository |
FedXFactory.createFederation(List<Endpoint> endpoints)
Create the federation by providing the endpoints to add.
|
static EndpointManager |
EndpointManager.initialize(List<Endpoint> endpoints)
Initialize the singleton endpoint manager with the provided endpoints
|
FedXFactory |
FedXFactory.withMembers(List<Endpoint> endpoints) |
Constructor and Description |
---|
FedX(List<Endpoint> endpoints) |
Modifier and Type | Field and Description |
---|---|
protected Endpoint |
ExclusiveGroup.ownedEndpoint |
Modifier and Type | Method and Description |
---|---|
Endpoint |
ExclusiveGroup.getOwnedEndpoint() |
Endpoint |
SingleSourceQuery.getSource() |
Constructor and Description |
---|
SingleSourceQuery(TupleExpr parsedQuery,
Endpoint source,
QueryInfo queryInfo) |
Modifier and Type | Method and Description |
---|---|
void |
FedXApi.addEndpoint(Endpoint e) |
void |
FedXApi.removeEndpoint(Endpoint e) |
Modifier and Type | Method and Description |
---|---|
TupleQueryResult |
FedXApi.evaluate(String query,
List<Endpoint> endpoints) |
Modifier and Type | Method and Description |
---|---|
SourceSelectionCache.StatementSourceAssurance |
SourceSelectionCache.getAssurance(SubQuery subQuery,
Endpoint endpoint)
Ask the cache if a given endpoint can provide results for a
SubQuery . |
SourceSelectionCache.StatementSourceAssurance |
SourceSelectionMemoryCache.getAssurance(SubQuery subQuery,
Endpoint endpoint) |
void |
SourceSelectionCache.updateInformation(SubQuery subQuery,
Endpoint endpoint,
boolean hasStatements)
|
void |
SourceSelectionMemoryCache.updateInformation(SubQuery subQuery,
Endpoint endpoint,
boolean hasStatements) |
Modifier and Type | Method and Description |
---|---|
static List<StatementSource> |
CacheUtils.checkCacheForStatementSourcesUpdateCache(SourceSelectionCache cache,
List<Endpoint> endpoints,
Resource subj,
IRI pred,
Value obj,
QueryInfo queryInfo,
Resource... contexts)
Checks the cache for relevant statement sources to the provided statement.
|
static boolean |
CacheUtils.checkCacheUpdateCache(SourceSelectionCache cache,
List<Endpoint> endpoints,
Resource subj,
IRI pred,
Value obj,
QueryInfo queryInfo,
Resource... contexts)
Checks the cache if some endpoint can provide results to the subquery.
|
Modifier and Type | Class and Description |
---|---|
class |
EndpointBase
Base implementation for an
Endpoint . |
class |
ManagedRepositoryEndpoint
A specialized
RepositoryEndpoint where the lifecycle of the Repository is managed by this endpoint,
i.e. |
class |
RepositoryEndpoint
A specialized
Endpoint that has a reference to a configured Repository . |
class |
ResolvableEndpoint
A specialized
Endpoint that allows to resolve the repository using a RepositoryResolver . |
Modifier and Type | Method and Description |
---|---|
static Endpoint |
EndpointFactory.loadEndpoint(String id,
Repository repository)
Load an
Endpoint for a given (configured) Repository. |
static Endpoint |
EndpointFactory.loadNativeEndpoint(File location)
Construct a
NativeStore endpoint using the provided information and the file location as name. |
static Endpoint |
EndpointFactory.loadNativeEndpoint(String name,
File location)
Construct a NativeStore endpoint using the provided information.
|
static Endpoint |
EndpointFactory.loadRemoteRepository(String repositoryServer,
String repositoryName) |
static Endpoint |
EndpointFactory.loadRemoteRepository(String repositoryServer,
String repositoryName,
boolean writable) |
static Endpoint |
EndpointFactory.loadResolvableRepository(String repositoryId)
Load a
ResolvableEndpoint |
static Endpoint |
EndpointFactory.loadResolvableRepository(String repositoryId,
boolean writable)
Load a
ResolvableEndpoint |
static Endpoint |
EndpointFactory.loadSPARQLEndpoint(String endpoint)
Construct a SPARQL endpoint using the the provided information and the host of the url as name.
|
static Endpoint |
EndpointFactory.loadSPARQLEndpoint(String name,
String endpoint)
Construct a SPARQL endpoint using the the provided information.
|
Modifier and Type | Method and Description |
---|---|
static List<Endpoint> |
EndpointFactory.loadFederationMembers(File dataConfig,
File fedXBaseDir)
Utility function to load federation members from a data configuration file.
|
static List<Endpoint> |
EndpointFactory.loadFederationMembers(Model members,
File baseDir)
Utility function to load federation members from a model.
|
Modifier and Type | Method and Description |
---|---|
Endpoint |
NativeStoreProvider.loadEndpoint(NativeRepositoryInformation repoInfo) |
Endpoint |
RemoteRepositoryProvider.loadEndpoint(RemoteRepositoryRepositoryInformation repoInfo) |
Endpoint |
RepositoryEndpointProvider.loadEndpoint(RepositoryInformation repoInfo) |
Endpoint |
ResolvableRepositoryProvider.loadEndpoint(ResolvableRepositoryInformation repoInfo) |
Endpoint |
SPARQLProvider.loadEndpoint(SPARQLRepositoryInformation repoInfo) |
Endpoint |
EndpointProvider.loadEndpoint(T repoInfo) |
Modifier and Type | Field and Description |
---|---|
protected Endpoint |
TripleSourceBase.endpoint |
Modifier and Type | Method and Description |
---|---|
protected Set<Endpoint> |
FederationEvalStrategy.performSourceSelection(List<Endpoint> members,
SourceSelectionCache cache,
QueryInfo queryInfo,
GenericInfoOptimizer info)
Perform source selection for all statements of the query.
|
Modifier and Type | Method and Description |
---|---|
static TripleSource |
TripleSourceFactory.tripleSourceFor(Endpoint e,
EndpointType t,
FederationContext federationContext) |
Modifier and Type | Method and Description |
---|---|
protected Set<Endpoint> |
FederationEvalStrategy.performSourceSelection(List<Endpoint> members,
SourceSelectionCache cache,
QueryInfo queryInfo,
GenericInfoOptimizer info)
Perform source selection for all statements of the query.
|
Constructor and Description |
---|
TripleSourceBase(FederationContext federationContext,
Endpoint endpoint) |
Modifier and Type | Field and Description |
---|---|
protected Endpoint |
ParallelUnionTask.endpoint |
protected Endpoint |
ParallelPreparedUnionTask.endpoint |
protected Endpoint |
ParallelGetStatementsTask.endpoint |
protected Endpoint |
ParallelPreparedAlgebraUnionTask.endpoint |
Constructor and Description |
---|
ParallelGetStatementsTask(ParallelExecutor<Statement> unionControl,
Endpoint endpoint,
Resource subj,
IRI pred,
Value obj,
QueryInfo queryInfo,
Resource... contexts) |
ParallelPreparedAlgebraUnionTask(ParallelExecutor<BindingSet> unionControl,
TupleExpr preparedQuery,
Endpoint endpoint,
BindingSet bindings,
FilterValueExpr filterExpr,
QueryInfo queryInfo) |
ParallelPreparedUnionTask(ParallelExecutor<BindingSet> unionControl,
String preparedQuery,
Endpoint endpoint,
BindingSet bindings,
FilterValueExpr filterExpr,
QueryInfo queryInfo) |
ParallelUnionTask(ParallelExecutor<BindingSet> unionControl,
StatementPattern stmt,
Endpoint endpoint,
BindingSet bindings,
FilterValueExpr filterExpr,
QueryInfo queryInfo) |
Modifier and Type | Method and Description |
---|---|
static QueryEvaluationException |
ExceptionUtil.traceExceptionSource(Endpoint endpoint,
Throwable ex,
String additionalInfo)
Trace the exception source within the exceptions to identify the originating endpoint.
|
static QueryEvaluationException |
ExceptionUtil.traceExceptionSourceAndRepair(Endpoint endpoint,
Throwable ex,
String additionalInfo)
Repair the connection and then trace the exception source.
|
Modifier and Type | Method and Description |
---|---|
Endpoint |
MonitoringImpl.MonitoringInformation.getE() |
Modifier and Type | Method and Description |
---|---|
MonitoringImpl.MonitoringInformation |
MonitoringImpl.getMonitoringInformation(Endpoint e) |
MonitoringImpl.MonitoringInformation |
MonitoringService.getMonitoringInformation(Endpoint e) |
void |
MonitoringImpl.monitorRemoteRequest(Endpoint e) |
void |
NoopMonitoringImpl.monitorRemoteRequest(Endpoint e) |
void |
Monitoring.monitorRemoteRequest(Endpoint e) |
Constructor and Description |
---|
MonitoringInformation(Endpoint e) |
Modifier and Type | Field and Description |
---|---|
Endpoint |
SourceSelection.CheckTaskPair.e |
protected Endpoint |
SourceSelection.ParallelCheckTask.endpoint |
Modifier and Type | Field and Description |
---|---|
protected List<Endpoint> |
SourceSelection.endpoints |
Modifier and Type | Method and Description |
---|---|
Set<Endpoint> |
SourceSelection.getRelevantSources()
Retrieve a set of relevant sources for this query.
|
Constructor and Description |
---|
CheckTaskPair(Endpoint e,
StatementPattern t,
QueryInfo queryInfo) |
ParallelCheckTask(Endpoint endpoint,
StatementPattern stmt,
QueryInfo queryInfo,
SourceSelection.SourceSelectionExecutorWithLatch control) |
Constructor and Description |
---|
SourceSelection(List<Endpoint> endpoints,
SourceSelectionCache cache,
QueryInfo queryInfo) |
Modifier and Type | Method and Description |
---|---|
WriteStrategy |
WriteStrategyFactory.create(List<Endpoint> members,
FederationContext federationContext)
Create the
WriteStrategy using the provided context |
WriteStrategy |
DefaultWriteStrategyFactory.create(List<Endpoint> members,
FederationContext federationContext) |
Copyright © 2015-2022 Eclipse Foundation. All Rights Reserved.