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

Class FederationAccessManagerWithCache

java.lang.Object

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

All Implemented Interfaces:

StatsProvider, FederationAccessManager

public class FederationAccessManagerWithCache
extends Object
implements FederationAccessManager

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	FederationAccessManagerWithCache.Key
protected static class	FederationAccessManagerWithCache.MyDefaultCachePolicies

Field Summary

Fields

Modifier and Type	Field	Description
protected final Cache<FederationAccessManagerWithCache.Key,CompletableFuture<? extends DataRetrievalResponse>>	cache
protected long	cacheHitsBRTPF
protected long	cacheHitsBRTPFCardinality
protected long	cacheHitsNeo4j
protected long	cacheHitsSPARQL
protected long	cacheHitsSPARQLCardinality
protected long	cacheHitsTPF
protected long	cacheHitsTPFCardinality
protected final Map<TriplePattern,CompletableFuture<CardinalityResponse>>	cacheMap
protected long	cacheRequestsBRTPF
protected long	cacheRequestsNeo4j
protected long	cacheRequestsSPARQL
protected long	cacheRequestsTPF
protected final FederationAccessManager	fedAccMan

Constructor Summary

Constructors

Constructor	Description
FederationAccessManagerWithCache(ExecutorService execService)	Creates a FederationAccessManagerWithCache with a default configuration.
FederationAccessManagerWithCache(FederationAccessManager fedAccMan, int cacheCapacity)
FederationAccessManagerWithCache(FederationAccessManager fedAccMan, int cacheCapacity, CachePolicies<FederationAccessManagerWithCache.Key,CompletableFuture<? extends DataRetrievalResponse>,? extends CacheEntry<CompletableFuture<? extends DataRetrievalResponse>>> cachePolicies)

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)
CompletableFuture<TPFResponse>	issueRequest(BRTPFRequest req, BRTPFServer fm)
CompletableFuture<RecordsResponse>	issueRequest(Neo4jRequest req, Neo4jServer fm)
CompletableFuture<SolMapsResponse>	issueRequest(SPARQLRequest req, SPARQLEndpoint fm)
CompletableFuture<TPFResponse>	issueRequest(TPFRequest req, BRTPFServer fm)
CompletableFuture<TPFResponse>	issueRequest(TPFRequest req, TPFServer fm)
void	resetStats()

Methods inherited from class java.lang.Object

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

Field Details

fedAccMan

protected final FederationAccessManager fedAccMan

cacheMap

protected final Map<TriplePattern,CompletableFuture<CardinalityResponse>> cacheMap

cache

protected final Cache<FederationAccessManagerWithCache.Key,CompletableFuture<? extends DataRetrievalResponse>> cache

cacheRequestsSPARQL

protected long cacheRequestsSPARQL

cacheRequestsTPF

protected long cacheRequestsTPF

cacheRequestsBRTPF

protected long cacheRequestsBRTPF

cacheRequestsNeo4j

protected long cacheRequestsNeo4j

cacheHitsSPARQL

protected long cacheHitsSPARQL

cacheHitsTPF

protected long cacheHitsTPF

cacheHitsBRTPF

protected long cacheHitsBRTPF

cacheHitsNeo4j

protected long cacheHitsNeo4j

cacheHitsSPARQLCardinality

protected long cacheHitsSPARQLCardinality

cacheHitsTPFCardinality

protected long cacheHitsTPFCardinality

cacheHitsBRTPFCardinality

protected long cacheHitsBRTPFCardinality

Constructor Details

FederationAccessManagerWithCache

public FederationAccessManagerWithCache(FederationAccessManager fedAccMan,
 int cacheCapacity,
 CachePolicies<FederationAccessManagerWithCache.Key,CompletableFuture<? extends DataRetrievalResponse>,? extends CacheEntry<CompletableFuture<? extends DataRetrievalResponse>>> cachePolicies)

FederationAccessManagerWithCache

public FederationAccessManagerWithCache(FederationAccessManager fedAccMan,
 int cacheCapacity)

FederationAccessManagerWithCache

public FederationAccessManagerWithCache(ExecutorService execService)

Creates a FederationAccessManagerWithCache with a default configuration.

Method Details

issueRequest

public CompletableFuture<SolMapsResponse> issueRequest(SPARQLRequest req,
 SPARQLEndpoint fm)
                                                throws FederationAccessException

Specified by:

issueRequest in interface FederationAccessManager

Throws:

FederationAccessException

issueRequest

public CompletableFuture<TPFResponse> issueRequest(TPFRequest req,
 TPFServer fm)
                                            throws FederationAccessException

Specified by:

issueRequest in interface FederationAccessManager

Throws:

FederationAccessException

issueRequest

public CompletableFuture<TPFResponse> issueRequest(TPFRequest req,
 BRTPFServer fm)
                                            throws FederationAccessException

Specified by:

issueRequest in interface FederationAccessManager

Throws:

FederationAccessException

issueRequest

public CompletableFuture<TPFResponse> issueRequest(BRTPFRequest req,
 BRTPFServer fm)
                                            throws FederationAccessException

Specified by:

issueRequest in interface FederationAccessManager

Throws:

FederationAccessException

issueRequest

public CompletableFuture<RecordsResponse> issueRequest(Neo4jRequest req,
 Neo4jServer fm)
                                                throws FederationAccessException

Specified by:

issueRequest in interface FederationAccessManager

Throws:

FederationAccessException

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

resetStats

public void resetStats()

Specified by:

resetStats in interface StatsProvider

getStats

public FederationAccessStats getStats()

Specified by:

getStats in interface FederationAccessManager

Specified by:

getStats in interface StatsProvider