Class FederationAccessManagerWithCache

java.lang.Object

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

All Implemented Interfaces:

StatsProvider, FederationAccessManager

Direct Known Subclasses:

FederationAccessManagerWithChronicleMapCache, FederationAccessManagerWithPersistedDiskCache

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	cacheHitsOther
protected long	cacheHitsSPARQL
protected long	cacheHitsSPARQLCardinality
protected long	cacheHitsTPF
protected long	cacheHitsTPFCardinality
protected final Map<TriplePattern,CompletableFuture<CardinalityResponse>>	cacheMap
protected long	cacheRequestsBRTPF
protected long	cacheRequestsOther
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)
<ReqType extends DataRetrievalRequest, RespType extends DataRetrievalResponse<?>, MemberType extends FederationMember> CompletableFuture<RespType>	issueRequest(ReqType req, MemberType fm)
void	resetStats()
void	shutdown()	Shuts down all thread pools associated with this federation access manager.

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

cacheRequestsOther

protected long cacheRequestsOther

cacheHitsSPARQL

protected long cacheHitsSPARQL

cacheHitsTPF

protected long cacheHitsTPF

cacheHitsBRTPF

protected long cacheHitsBRTPF

cacheHitsOther

protected long cacheHitsOther

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 <ReqType extends DataRetrievalRequest,
RespType extends DataRetrievalResponse<?>,
MemberType extends FederationMember>
CompletableFuture<RespType> issueRequest(ReqType req,
 MemberType 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

shutdown

public void shutdown()

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

Specified by:

shutdown in interface FederationAccessManager