| 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)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)Checks the cache if some endpoint can provide results to the subquery. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | EndpointBaseBase implementation for an  Endpoint. | 
| class  | ManagedRepositoryEndpointA specialized  RepositoryEndpointwhere the lifecycle of theRepositoryis managed by this endpoint,
 i.e. | 
| class  | RepositoryEndpointA specialized  Endpointthat has a reference to a configuredRepository. | 
| class  | ResolvableEndpointA specialized  Endpointthat allows to resolve the repository using aRepositoryResolver. | 
| Modifier and Type | Method and Description | 
|---|---|
| static Endpoint | EndpointFactory. loadEndpoint(String id,
            Repository repository)Load an  EndpointBasefor a given (configured) Repository. | 
| static Endpoint | EndpointFactory. loadNativeEndpoint(File location)Construct a  NativeStoreendpoint 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. loadResolvableRepository(String repositoryId)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) | 
Copyright © 2015-2020 Eclipse Foundation. All Rights Reserved.