Class FederationAccessManagerBase1

java.lang.Object

se.liu.ida.hefquin.federation.access.impl.FederationAccessManagerBase1

All Implemented Interfaces:

StatsProvider, FederationAccessManager

Direct Known Subclasses:

FederationAccessManagerBase2

public abstract class FederationAccessManagerBase1
extends Object
implements FederationAccessManager

As a basis for classes that implement the FederationAccessManager interface, this abstract base class provides default implementations of the methods for issuing cardinality requests. These implementations issue specific data fetching requests via which the desired cardinality estimates can be obtained.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	FederationAccessManagerBase1.FunctionToObtainCardinalityResponseFromSolMapsResponse
protected static class	FederationAccessManagerBase1.FunctionToObtainCardinalityResponseFromTPFResponse

Field Summary

Fields

Modifier and Type	Field	Description
protected static final org.apache.jena.sparql.core.Var	countVar
static final String	enNumberOfBRTPFCardRequestsIssued
static final String	enNumberOfSPARQLCardRequestsIssued
static final String	enNumberOfTPFCardRequestsIssued
static final String	enOverallNumberOfCardRequestsIssued
protected static final Function<SolMapsResponse,CardinalityResponse>	fctToObtainCardinalityResponseFromSolMapsResponse
protected static final Function<TPFResponse,CardinalityResponse>	fctToObtainCardinalityResponseFromTPFResponse
protected AtomicLong	issuedCardRequestsBRTPF
protected AtomicLong	issuedCardRequestsSPARQL
protected AtomicLong	issuedCardRequestsTPF

Constructor Summary

Constructors

Constructor	Description
FederationAccessManagerBase1()

Method Summary

Modifier and Type	Method	Description
protected abstract FederationAccessStatsImpl	_getStats()
CompletableFuture<CardinalityResponse>	_issueCardinalityRequest(BRTPFRequest req, BRTPFServer fm, boolean ignoreCardinalityCache)
CompletableFuture<CardinalityResponse>	_issueCardinalityRequest(SPARQLRequest req, SPARQLEndpoint fm, boolean ignoreCardinalityCache)
CompletableFuture<CardinalityResponse>	_issueCardinalityRequest(TPFRequest req, BRTPFServer fm, boolean ignoreCardinalityCache)
CompletableFuture<CardinalityResponse>	_issueCardinalityRequest(TPFRequest req, TPFServer fm, boolean ignoreCardinalityCache)
protected abstract void	_resetStats()
final FederationAccessStats	getStats()
<ReqType extends DataRetrievalRequest, RespType extends DataRetrievalResponse<?>, MemberType extends FederationMember> CompletableFuture<CardinalityResponse>	issueCardinalityRequest(ReqType req, MemberType fm, boolean ignoreCardinalityCache)
final void	resetStats()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface se.liu.ida.hefquin.federation.access.FederationAccessManager

issueRequest, shutdown

Field Details

enOverallNumberOfCardRequestsIssued

public static final String enOverallNumberOfCardRequestsIssued

See Also:

• Constant Field Values

enNumberOfSPARQLCardRequestsIssued

public static final String enNumberOfSPARQLCardRequestsIssued

See Also:

• Constant Field Values

enNumberOfTPFCardRequestsIssued

public static final String enNumberOfTPFCardRequestsIssued

See Also:

• Constant Field Values

enNumberOfBRTPFCardRequestsIssued

public static final String enNumberOfBRTPFCardRequestsIssued

See Also:

• Constant Field Values

countVar

protected static final org.apache.jena.sparql.core.Var countVar

fctToObtainCardinalityResponseFromSolMapsResponse

protected static final Function<SolMapsResponse,CardinalityResponse> fctToObtainCardinalityResponseFromSolMapsResponse

fctToObtainCardinalityResponseFromTPFResponse

protected static final Function<TPFResponse,CardinalityResponse> fctToObtainCardinalityResponseFromTPFResponse

issuedCardRequestsSPARQL

protected AtomicLong issuedCardRequestsSPARQL

issuedCardRequestsTPF

protected AtomicLong issuedCardRequestsTPF

issuedCardRequestsBRTPF

protected AtomicLong issuedCardRequestsBRTPF

Constructor Details

FederationAccessManagerBase1

public FederationAccessManagerBase1()

Method Details

issueCardinalityRequest

public <ReqType extends DataRetrievalRequest,
RespType extends DataRetrievalResponse<?>,
MemberType extends FederationMember>
CompletableFuture<CardinalityResponse> issueCardinalityRequest(ReqType req,
 MemberType fm,
 boolean ignoreCardinalityCache)

Specified by:

issueCardinalityRequest in interface FederationAccessManager

_issueCardinalityRequest

public CompletableFuture<CardinalityResponse> _issueCardinalityRequest(SPARQLRequest req,
 SPARQLEndpoint fm,
 boolean ignoreCardinalityCache)

_issueCardinalityRequest

public CompletableFuture<CardinalityResponse> _issueCardinalityRequest(TPFRequest req,
 TPFServer fm,
 boolean ignoreCardinalityCache)

_issueCardinalityRequest

public CompletableFuture<CardinalityResponse> _issueCardinalityRequest(TPFRequest req,
 BRTPFServer fm,
 boolean ignoreCardinalityCache)

_issueCardinalityRequest

public CompletableFuture<CardinalityResponse> _issueCardinalityRequest(BRTPFRequest req,
 BRTPFServer fm,
 boolean ignoreCardinalityCache)

getStats

public final FederationAccessStats getStats()

Specified by:

getStats in interface FederationAccessManager

Specified by:

getStats in interface StatsProvider

resetStats

public final void resetStats()

Specified by:

resetStats in interface StatsProvider

_getStats

protected abstract FederationAccessStatsImpl _getStats()

_resetStats

protected abstract void _resetStats()