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

Class AsyncFederationAccessManagerImpl

java.lang.Object

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

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

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

All Implemented Interfaces:

StatsProvider, FederationAccessManager

public class AsyncFederationAccessManagerImpl
extends FederationAccessManagerBase2

Nested Class Summary

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

FederationAccessManagerBase1.FunctionToObtainCardinalityResponseFromSolMapsResponse, FederationAccessManagerBase1.FunctionToObtainCardinalityResponseFromTPFResponse

Field Summary

Fields

Modifier and Type	Field	Description
protected AtomicLong	completedBRTPFRequests
protected AtomicLong	completedNeo4jRequests
protected AtomicLong	completedSPARQLRequests
protected AtomicLong	completedTPFRequests
protected AtomicLong	issuedBRTPFRequests
protected AtomicLong	issuedNeo4jRequests
protected AtomicLong	issuedSPARQLRequests
protected AtomicLong	issuedTPFRequests
protected final ExecutorService	threadPool

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

reqProcBRTPF, reqProcNeo4j, reqProcSPARQL, reqProcTPF

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

countVar, enNumberOfBRTPFCardRequestsIssued, enNumberOfSPARQLCardRequestsIssued, enNumberOfTPFCardRequestsIssued, enOverallNumberOfCardRequestsIssued, issuedCardRequestsBRTPF, issuedCardRequestsSPARQL, issuedCardRequestsTPF

Constructor Summary

Constructors

Constructor	Description
AsyncFederationAccessManagerImpl(ExecutorService execService)	Creates an AsyncFederationAccessManagerImpl with a default configuration.
AsyncFederationAccessManagerImpl(ExecutorService execService, SPARQLRequestProcessor reqProcSPARQL, TPFRequestProcessor reqProcTPF, BRTPFRequestProcessor reqProcBRTPF, Neo4jRequestProcessor reqProcNeo4j)

Method Summary

Modifier and Type	Method	Description
protected FederationAccessStatsImpl	_getStats()
protected void	_resetStats()
protected Supplier<TPFResponse>	createSupplier(BRTPFRequest req, BRTPFServer fm)
protected Supplier<RecordsResponse>	createSupplier(Neo4jRequest req, Neo4jServer fm)
protected Supplier<SolMapsResponse>	createSupplier(SPARQLRequest req, SPARQLEndpoint fm)
protected Supplier<TPFResponse>	createSupplier(TPFRequest req, BRTPFServer fm)
protected Supplier<TPFResponse>	createSupplier(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)

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

getFctToObtainCardinalityResponseFromSolMapsResponse, getFctToObtainCardinalityResponseFromTPFResponse, getStats, issueCardinalityRequest, issueCardinalityRequest, issueCardinalityRequest, issueCardinalityRequest, resetStats

Methods inherited from class java.lang.Object

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

Field Details

threadPool

protected final ExecutorService threadPool

issuedSPARQLRequests

protected AtomicLong issuedSPARQLRequests

issuedTPFRequests

protected AtomicLong issuedTPFRequests

issuedBRTPFRequests

protected AtomicLong issuedBRTPFRequests

issuedNeo4jRequests

protected AtomicLong issuedNeo4jRequests

completedSPARQLRequests

protected AtomicLong completedSPARQLRequests

completedTPFRequests

protected AtomicLong completedTPFRequests

completedBRTPFRequests

protected AtomicLong completedBRTPFRequests

completedNeo4jRequests

protected AtomicLong completedNeo4jRequests

Constructor Details

AsyncFederationAccessManagerImpl

public AsyncFederationAccessManagerImpl(ExecutorService execService,
 SPARQLRequestProcessor reqProcSPARQL,
 TPFRequestProcessor reqProcTPF,
 BRTPFRequestProcessor reqProcBRTPF,
 Neo4jRequestProcessor reqProcNeo4j)

AsyncFederationAccessManagerImpl

public AsyncFederationAccessManagerImpl(ExecutorService execService)

Creates an AsyncFederationAccessManagerImpl with a default configuration.

Method Details

issueRequest

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

issueRequest

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

issueRequest

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

issueRequest

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

issueRequest

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

_getStats

protected FederationAccessStatsImpl _getStats()

Specified by:

_getStats in class FederationAccessManagerBase1

_resetStats

protected void _resetStats()

Specified by:

_resetStats in class FederationAccessManagerBase1

createSupplier

protected Supplier<SolMapsResponse> createSupplier(SPARQLRequest req,
 SPARQLEndpoint fm)

createSupplier

protected Supplier<TPFResponse> createSupplier(TPFRequest req,
 TPFServer fm)

createSupplier

protected Supplier<TPFResponse> createSupplier(TPFRequest req,
 BRTPFServer fm)

createSupplier

protected Supplier<TPFResponse> createSupplier(BRTPFRequest req,
 BRTPFServer fm)

createSupplier

protected Supplier<RecordsResponse> createSupplier(Neo4jRequest req,
 Neo4jServer fm)