Package se.liu.ida.hefquin.engine.federation.access.impl

Class FederationAccessManagerBase1

java.lang.Object

se.liu.ida.hefquin.engine.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 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()
protected abstract void	_resetStats()
protected Function<SolMapsResponse,CardinalityResponse>	getFctToObtainCardinalityResponseFromSolMapsResponse()
protected Function<TPFResponse,CardinalityResponse>	getFctToObtainCardinalityResponseFromTPFResponse()
final 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)
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.engine.federation.access.FederationAccessManager

issueRequest, issueRequest, issueRequest, issueRequest, issueRequest

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

issuedCardRequestsSPARQL

protected AtomicLong issuedCardRequestsSPARQL

issuedCardRequestsTPF

protected AtomicLong issuedCardRequestsTPF

issuedCardRequestsBRTPF

protected AtomicLong issuedCardRequestsBRTPF

Constructor Details

FederationAccessManagerBase1

public FederationAccessManagerBase1()

Method Details

issueCardinalityRequest

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

Description copied from interface: FederationAccessManager

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.

Specified by:

issueCardinalityRequest in interface FederationAccessManager

Throws:

FederationAccessException

issueCardinalityRequest

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

Specified by:

issueCardinalityRequest in interface FederationAccessManager

Throws:

FederationAccessException

issueCardinalityRequest

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

Specified by:

issueCardinalityRequest in interface FederationAccessManager

Throws:

FederationAccessException

issueCardinalityRequest

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

Specified by:

issueCardinalityRequest in interface FederationAccessManager

Throws:

FederationAccessException

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()

getFctToObtainCardinalityResponseFromSolMapsResponse

protected Function<SolMapsResponse,CardinalityResponse> getFctToObtainCardinalityResponseFromSolMapsResponse()

getFctToObtainCardinalityResponseFromTPFResponse

protected Function<TPFResponse,CardinalityResponse> getFctToObtainCardinalityResponseFromTPFResponse()