Interface FederationAccessManager

All Superinterfaces:

StatsProvider

All Known Implementing Classes:

AsyncFederationAccessManagerImpl, BlockingFederationAccessManagerImpl, FederationAccessManagerBase1, FederationAccessManagerBase2, FederationAccessManagerWithCache, FederationAccessManagerWithChronicleMapCache, FederationAccessManagerWithPersistedDiskCache

public interface FederationAccessManager
extends StatsProvider

Method Summary

Modifier and Type	Method	Description
FederationAccessStats	getStats()
CompletableFuture<CardinalityResponse>	issueCardinalityRequest(BRTPFRequest req, BRTPFServer fm)
CompletableFuture<CardinalityResponse>	issueCardinalityRequest(SPARQLRequest req, SPARQLEndpoint fm)	Requests the cardinality of the result of the given request.
CompletableFuture<CardinalityResponse>	issueCardinalityRequest(TPFRequest req, BRTPFServer fm)
CompletableFuture<CardinalityResponse>	issueCardinalityRequest(TPFRequest req, TPFServer fm)
<ReqType extends DataRetrievalRequest, RespType extends DataRetrievalResponse<?>, MemberType extends FederationMember> CompletableFuture<RespType>	issueRequest(ReqType req, MemberType fm)
void	shutdown()	Shuts down all thread pools associated with this federation access manager.

Methods inherited from interface se.liu.ida.hefquin.base.utils.StatsProvider

resetStats

Method Details

issueRequest

<ReqType extends DataRetrievalRequest,
RespType extends DataRetrievalResponse<?>,
MemberType extends FederationMember>
CompletableFuture<RespType> issueRequest(ReqType req,
 MemberType fm)
                                  throws FederationAccessException

Throws:

FederationAccessException

issueCardinalityRequest

CompletableFuture<CardinalityResponse> issueCardinalityRequest(SPARQLRequest req,
 SPARQLEndpoint fm)
                                                        throws FederationAccessException

Requests the cardinality of the result of the given request. Assumes that the given request contains a SPARQLGraphPattern rather than a full SPARQLQuery. If it does not, then this method throws an IllegalArgumentException.

Throws:

FederationAccessException

issueCardinalityRequest

CompletableFuture<CardinalityResponse> issueCardinalityRequest(TPFRequest req,
 TPFServer fm)
                                                        throws FederationAccessException

Throws:

FederationAccessException

issueCardinalityRequest

CompletableFuture<CardinalityResponse> issueCardinalityRequest(TPFRequest req,
 BRTPFServer fm)
                                                        throws FederationAccessException

Throws:

FederationAccessException

issueCardinalityRequest

CompletableFuture<CardinalityResponse> issueCardinalityRequest(BRTPFRequest req,
 BRTPFServer fm)
                                                        throws FederationAccessException

Throws:

FederationAccessException

getStats

FederationAccessStats getStats()

Specified by:

getStats in interface StatsProvider

shutdown

void shutdown()

Shuts down all thread pools associated with this federation access manager.