Class FederationAccessManagerWithChronicleMapCache

java.lang.Object

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

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

All Implemented Interfaces:

StatsProvider, FederationAccessManager

public class FederationAccessManagerWithChronicleMapCache
extends FederationAccessManagerWithCache

A FederationAccessManager implementation that incorporates persistent disk caching of cardinality requests.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	FederationAccessManagerWithChronicleMapCache.MyDefaultCardinalityCachePolicies

Nested classes/interfaces inherited from class se.liu.ida.hefquin.engine.federation.access.impl.FederationAccessManagerWithCache

FederationAccessManagerWithCache.Key, FederationAccessManagerWithCache.MyDefaultCachePolicies

Field Summary

Fields

Modifier and Type	Field	Description
protected final ChronicleMapCardinalityCache	cardinalityCache
protected static final int	defaultCacheCapacity

Fields inherited from class se.liu.ida.hefquin.engine.federation.access.impl.FederationAccessManagerWithCache

cache, cacheHitsBRTPF, cacheHitsBRTPFCardinality, cacheHitsNeo4j, cacheHitsSPARQL, cacheHitsSPARQLCardinality, cacheHitsTPF, cacheHitsTPFCardinality, cacheMap, cacheRequestsBRTPF, cacheRequestsNeo4j, cacheRequestsSPARQL, cacheRequestsTPF, fedAccMan

Constructor Summary

Constructors

Constructor	Description
FederationAccessManagerWithChronicleMapCache(ExecutorService execService)	Creates a FederationAccessManagerWithChronicleMapCache with the default configuration.
FederationAccessManagerWithChronicleMapCache(FederationAccessManager fedAccMan, int cacheCapacity, long timeToLive)
FederationAccessManagerWithChronicleMapCache(FederationAccessManager fedAccMan, int cacheCapacity, CachePolicies<FederationAccessManagerWithCache.Key,CompletableFuture<? extends DataRetrievalResponse<?>>,? extends CacheEntry<CompletableFuture<? extends DataRetrievalResponse<?>>>> cachePolicies, CachePolicies<CardinalityCacheKey,Integer,CardinalityCacheEntry> cardinalityCachePolicies)

Method Summary

Modifier and Type	Method	Description
void	clearCardinalityCache()	Clears the persisted cardinality cache map.
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)

Methods inherited from class se.liu.ida.hefquin.engine.federation.access.impl.FederationAccessManagerWithCache

getStats, issueRequest, issueRequest, issueRequest, issueRequest, issueRequest, resetStats, shutdown

Methods inherited from class java.lang.Object

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

Field Details

cardinalityCache

protected final ChronicleMapCardinalityCache cardinalityCache

defaultCacheCapacity

protected static final int defaultCacheCapacity

See Also:

• Constant Field Values

Constructor Details

FederationAccessManagerWithChronicleMapCache

public FederationAccessManagerWithChronicleMapCache(FederationAccessManager fedAccMan,
 int cacheCapacity,
 CachePolicies<FederationAccessManagerWithCache.Key,CompletableFuture<? extends DataRetrievalResponse<?>>,? extends CacheEntry<CompletableFuture<? extends DataRetrievalResponse<?>>>> cachePolicies,
 CachePolicies<CardinalityCacheKey,Integer,CardinalityCacheEntry> cardinalityCachePolicies)
                                             throws IOException

Throws:

IOException

FederationAccessManagerWithChronicleMapCache

public FederationAccessManagerWithChronicleMapCache(FederationAccessManager fedAccMan,
 int cacheCapacity,
 long timeToLive)
                                             throws IOException

Throws:

IOException

FederationAccessManagerWithChronicleMapCache

public FederationAccessManagerWithChronicleMapCache(ExecutorService execService)
                                             throws IOException

Creates a FederationAccessManagerWithChronicleMapCache with the default configuration.

Throws:

IOException

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

Overrides:

issueCardinalityRequest in class FederationAccessManagerWithCache

Throws:

FederationAccessException

issueCardinalityRequest

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

Specified by:

issueCardinalityRequest in interface FederationAccessManager

Overrides:

issueCardinalityRequest in class FederationAccessManagerWithCache

Throws:

FederationAccessException

issueCardinalityRequest

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

Specified by:

issueCardinalityRequest in interface FederationAccessManager

Overrides:

issueCardinalityRequest in class FederationAccessManagerWithCache

Throws:

FederationAccessException

issueCardinalityRequest

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

Specified by:

issueCardinalityRequest in interface FederationAccessManager

Overrides:

issueCardinalityRequest in class FederationAccessManagerWithCache

Throws:

FederationAccessException

clearCardinalityCache

public void clearCardinalityCache()

Clears the persisted cardinality cache map.