Uses of Interface
se.liu.ida.hefquin.federation.access.DataRetrievalResponse
Packages that use DataRetrievalResponse
Package
Description
-
Uses of DataRetrievalResponse in se.liu.ida.hefquin.engine.federation.access.utils
Methods in se.liu.ida.hefquin.engine.federation.access.utils with type parameters of type DataRetrievalResponseModifier and TypeMethodDescriptionstatic <ReqType extends DataRetrievalRequest,RespType extends DataRetrievalResponse<?>, MemberType extends FederationMember>
RespTypeFederationAccessUtils.performRequest(QueryProcContext ctx, ReqType req, MemberType fm) Methods in se.liu.ida.hefquin.engine.federation.access.utils that return DataRetrievalResponseModifier and TypeMethodDescriptionstatic DataRetrievalResponse<?>[]FederationAccessUtils.performRequest(QueryProcContext ctx, LogicalOpRequest<?, ?>... reqOps) -
Uses of DataRetrievalResponse in se.liu.ida.hefquin.engine.queryplan.executable.impl.ops
Classes in se.liu.ida.hefquin.engine.queryplan.executable.impl.ops with type parameters of type DataRetrievalResponseModifier and TypeClassDescriptionclassBaseForExecOpIndexNestedLoopsJoinWithRequests<QueryType extends Query,MemberType extends FederationMember, ReqType extends DataRetrievalRequest, RespType extends DataRetrievalResponse<?>> Abstract base class to implement index nested loops joins by issuing requests directly and, then, using response processors.classBaseForExecOpParallelBindJoin<QueryType extends Query,MemberType extends FederationMember, ReqType extends DataRetrievalRequest, RespType extends DataRetrievalResponse<?>> A generic implementation of a batch-based bind-join algorithm that issues the bind-join requests without blocking, handling the processing of their responses in parallel (in the threads that the federation access manager uses to perform the requests).classBaseForExecOpRequestWithPaging<ReqType extends DataRetrievalRequest,MemberType extends FederationMember, PageReqType extends DataRetrievalRequest, PageRespType extends DataRetrievalResponse<?>> Base class for implementations of request operators with requests that have to be broken into multiple requests to handle paging. -
Uses of DataRetrievalResponse in se.liu.ida.hefquin.engine.wrappers.lpg.access
Subinterfaces of DataRetrievalResponse in se.liu.ida.hefquin.engine.wrappers.lpg.accessClasses in se.liu.ida.hefquin.engine.wrappers.lpg.access that implement DataRetrievalResponseMethod parameters in se.liu.ida.hefquin.engine.wrappers.lpg.access with type arguments of type DataRetrievalResponseModifier and TypeMethodDescriptiondefault booleanRecordsRetrievalProcessor.isSupportedResponseType(Class<? extends DataRetrievalResponse<?>> t) -
Uses of DataRetrievalResponse in se.liu.ida.hefquin.federation.access
Subinterfaces of DataRetrievalResponse in se.liu.ida.hefquin.federation.accessModifier and TypeInterfaceDescriptioninterfaceinterfaceinterfaceinterfaceinterfaceinterfaceMethods in se.liu.ida.hefquin.federation.access with type parameters of type DataRetrievalResponseModifier and TypeMethodDescription<ReqType extends DataRetrievalRequest,RespType extends DataRetrievalResponse<?>, MemberType extends FederationMember>
CompletableFuture<CardinalityResponse> FederationAccessManager.issueCardinalityRequest(ReqType req, MemberType fm, boolean ignoreCardinalityCache) <ReqType extends DataRetrievalRequest,RespType extends DataRetrievalResponse<?>, MemberType extends FederationMember>
CompletableFuture<RespType> FederationAccessManager.issueRequest(ReqType req, MemberType fm, boolean ignoreRetrievalCache) -
Uses of DataRetrievalResponse in se.liu.ida.hefquin.federation.access.impl
Classes in se.liu.ida.hefquin.federation.access.impl with type parameters of type DataRetrievalResponseModifier and TypeInterfaceDescriptioninterfaceRequestProcessor<ReqType extends DataRetrievalRequest,RespType extends DataRetrievalResponse<?>, MemberType extends FederationMember> This interface captures any kind of request processor.Classes in se.liu.ida.hefquin.federation.access.impl that implement interfaces with type arguments of type DataRetrievalResponseModifier and TypeClassDescriptionprotected static classprotected static classstatic classDefault cache policies forHierarchicalCache.Fields in se.liu.ida.hefquin.federation.access.impl with type parameters of type DataRetrievalResponseModifier and TypeFieldDescriptionprotected final HierarchicalCache<PersistentCacheKey, CompletableFuture<? extends DataRetrievalResponse<?>>, PersistentCacheEntry> FederationAccessManagerWithHierarchicalCache.cacheprotected final Cache<FederationAccessManagerWithCache.Key, CompletableFuture<? extends DataRetrievalResponse<?>>> FederationAccessManagerWithCache.cardinalityCacheprotected final Cache<FederationAccessManagerWithCache.Key, CompletableFuture<? extends DataRetrievalResponse<?>>> FederationAccessManagerWithCache.retrievalCacheMethods in se.liu.ida.hefquin.federation.access.impl with type parameters of type DataRetrievalResponseModifier and TypeMethodDescriptionprotected <ReqType extends DataRetrievalRequest,RespType extends DataRetrievalResponse<?>, MemberType extends FederationMember>
RequestProcessor<ReqType, RespType, MemberType> FederationAccessManagerBase2.getReqProc(ReqType req, MemberType fm) <ReqType extends DataRetrievalRequest,RespType extends DataRetrievalResponse<?>, MemberType extends FederationMember>
CompletableFuture<CardinalityResponse> FederationAccessManagerBase1.issueCardinalityRequest(ReqType req, MemberType fm, boolean ignoreCardinalityCache) <ReqType extends DataRetrievalRequest,RespType extends DataRetrievalResponse<?>, MemberType extends FederationMember>
CompletableFuture<CardinalityResponse> FederationAccessManagerWithCache.issueCardinalityRequest(ReqType req, MemberType fm, boolean ignoreCardinalityCache) <ReqType extends DataRetrievalRequest,RespType extends DataRetrievalResponse<?>, MemberType extends FederationMember>
CompletableFuture<CardinalityResponse> FederationAccessManagerWithHierarchicalCache.issueCardinalityRequest(ReqType req, MemberType fm, boolean ignoreCardinalityCache) Issues a cardinality request for the given request and federation member.<ReqType extends DataRetrievalRequest,RespType extends DataRetrievalResponse<?>, MemberType extends FederationMember>
CompletableFuture<RespType> AsyncFederationAccessManagerImpl.issueRequest(ReqType req, MemberType fm, boolean ignoreRetrievalCache) <ReqType extends DataRetrievalRequest,RespType extends DataRetrievalResponse<?>, MemberType extends FederationMember>
CompletableFuture<RespType> BlockingFederationAccessManagerImpl.issueRequest(ReqType req, MemberType fm, boolean ignoreRetrievalCache) <ReqType extends DataRetrievalRequest,RespType extends DataRetrievalResponse<?>, MemberType extends FederationMember>
CompletableFuture<RespType> FederationAccessManagerWithCache.issueRequest(ReqType req, MemberType fm, boolean ignoreCache) <ReqType extends DataRetrievalRequest,RespType extends DataRetrievalResponse<?>, MemberType extends FederationMember>
CompletableFuture<RespType> FederationAccessManagerWithHierarchicalCache.issueRequest(ReqType req, MemberType fm, boolean ignoreRetrievalCache) Issues a request for the given request and federation member.Methods in se.liu.ida.hefquin.federation.access.impl that return types with arguments of type DataRetrievalResponseModifier and TypeMethodDescriptionCacheEntryFactory<CacheEntryBase<CompletableFuture<? extends DataRetrievalResponse<?>>>, CompletableFuture<? extends DataRetrievalResponse<?>>> FederationAccessManagerWithCache.MyDefaultCachePolicies.getEntryFactory()CacheEntryFactory<CacheEntryBase<CompletableFuture<? extends DataRetrievalResponse<?>>>, CompletableFuture<? extends DataRetrievalResponse<?>>> FederationAccessManagerWithCache.MyDefaultCachePolicies.getEntryFactory()CacheInvalidationPolicy<CacheEntryBase<CompletableFuture<? extends DataRetrievalResponse<?>>>, CompletableFuture<? extends DataRetrievalResponse<?>>> FederationAccessManagerWithCache.MyDefaultCachePolicies.getInvalidationPolicy()CacheInvalidationPolicy<CacheEntryBase<CompletableFuture<? extends DataRetrievalResponse<?>>>, CompletableFuture<? extends DataRetrievalResponse<?>>> FederationAccessManagerWithCache.MyDefaultCachePolicies.getInvalidationPolicy()FederationAccessManagerWithHierarchicalCache.DefaultHierarchicalMapCachePolicies.getInvalidationPolicy()CacheReplacementPolicyFactory<FederationAccessManagerWithCache.Key, CompletableFuture<? extends DataRetrievalResponse<?>>, CacheEntryBase<CompletableFuture<? extends DataRetrievalResponse<?>>>> FederationAccessManagerWithCache.MyDefaultCachePolicies.getReplacementPolicyFactory()CacheReplacementPolicyFactory<FederationAccessManagerWithCache.Key, CompletableFuture<? extends DataRetrievalResponse<?>>, CacheEntryBase<CompletableFuture<? extends DataRetrievalResponse<?>>>> FederationAccessManagerWithCache.MyDefaultCachePolicies.getReplacementPolicyFactory()CacheReplacementPolicyFactory<PersistentCacheKey, CompletableFuture<? extends DataRetrievalResponse<?>>, PersistentCacheEntry> FederationAccessManagerWithHierarchicalCache.DefaultHierarchicalMapCachePolicies.getReplacementPolicyFactory()Method parameters in se.liu.ida.hefquin.federation.access.impl with type arguments of type DataRetrievalResponseModifier and TypeMethodDescriptionbooleanRequestProcessor.isSupportedResponseType(Class<? extends DataRetrievalResponse<?>> t) Constructor parameters in se.liu.ida.hefquin.federation.access.impl with type arguments of type DataRetrievalResponseModifierConstructorDescriptionFederationAccessManagerWithCache(FederationAccessManager fedAccMan, int cacheCapacity, CachePolicies<FederationAccessManagerWithCache.Key, CompletableFuture<? extends DataRetrievalResponse<?>>, ? extends CacheEntry<CompletableFuture<? extends DataRetrievalResponse<?>>>> cachePolicies) FederationAccessManagerWithCache(FederationAccessManager fedAccMan, int cacheCapacity, CachePolicies<FederationAccessManagerWithCache.Key, CompletableFuture<? extends DataRetrievalResponse<?>>, ? extends CacheEntry<CompletableFuture<? extends DataRetrievalResponse<?>>>> cachePolicies) FederationAccessManagerWithHierarchicalCache(FederationAccessManager fedAccMan, Cache<PersistentCacheKey, CompletableFuture<? extends DataRetrievalResponse<?>>> l1Cache, Cache<PersistentCacheKey, CompletableFuture<? extends DataRetrievalResponse<?>>> l2Cache) Creates a federation access manager with a ChronicleMap-backed persistent cache using the given capacity and cache policies. -
Uses of DataRetrievalResponse in se.liu.ida.hefquin.federation.access.impl.cache
Subclasses with type arguments of type DataRetrievalResponse in se.liu.ida.hefquin.federation.access.impl.cacheModifier and TypeClassDescriptionclassCache entry implementation for persistent caching.Classes in se.liu.ida.hefquin.federation.access.impl.cache that implement interfaces with type arguments of type DataRetrievalResponseModifier and TypeClassDescriptionclassFactory for creatingPersistentCacheEntryinstances with the current system time as creation timestamp.Method parameters in se.liu.ida.hefquin.federation.access.impl.cache with type arguments of type DataRetrievalResponseModifier and TypeMethodDescriptionPersistentCacheEntryFactory.createCacheEntry(CompletableFuture<? extends DataRetrievalResponse<?>> object) Creates a new cache entry for the given object, using the current time (in milliseconds since the epoch) as the creation timestamp.Constructor parameters in se.liu.ida.hefquin.federation.access.impl.cache with type arguments of type DataRetrievalResponseModifierConstructorDescriptionPersistentCacheEntry(CompletableFuture<? extends DataRetrievalResponse<?>> object, long creationTime) Creates a new cache entry. -
Uses of DataRetrievalResponse in se.liu.ida.hefquin.federation.access.impl.cache.chroniclemap
Subclasses with type arguments of type DataRetrievalResponse in se.liu.ida.hefquin.federation.access.impl.cache.chroniclemapModifier and TypeClassDescriptionclassPersistent cache backed by aChronicleMap.Method parameters in se.liu.ida.hefquin.federation.access.impl.cache.chroniclemap with type arguments of type DataRetrievalResponseModifier and TypeMethodDescriptionvoidChronicleMapCache.put(PersistentCacheKey key, CompletableFuture<? extends DataRetrievalResponse<?>> value) Inserts or updates a cache entry once the given future completes successfully.Constructor parameters in se.liu.ida.hefquin.federation.access.impl.cache.chroniclemap with type arguments of type DataRetrievalResponseModifierConstructorDescriptionChronicleMapCache(int capacity, String filename, CachePolicies<PersistentCacheKey, CompletableFuture<? extends DataRetrievalResponse<?>>, PersistentCacheEntry> policies) Creates a cache with the given capacity and file path.ChronicleMapCache(int capacity, CachePolicies<PersistentCacheKey, CompletableFuture<? extends DataRetrievalResponse<?>>, PersistentCacheEntry> policies) Creates a cache with the given capacity and the default file path.ChronicleMapCache(String filename, CachePolicies<PersistentCacheKey, CompletableFuture<? extends DataRetrievalResponse<?>>, PersistentCacheEntry> policies) Constructs a newChronicleMapCachewith a custom file path and the default cache capacity.ChronicleMapCache(CachePolicies<PersistentCacheKey, CompletableFuture<? extends DataRetrievalResponse<?>>, PersistentCacheEntry> policies) Creates a cache with the default capacity and default file path. -
Uses of DataRetrievalResponse in se.liu.ida.hefquin.federation.access.impl.cache.mapdb
Subclasses with type arguments of type DataRetrievalResponse in se.liu.ida.hefquin.federation.access.impl.cache.mapdbMethod parameters in se.liu.ida.hefquin.federation.access.impl.cache.mapdb with type arguments of type DataRetrievalResponseModifier and TypeMethodDescriptionvoidMapDBCache.put(PersistentCacheKey key, CompletableFuture<? extends DataRetrievalResponse<?>> value) Inserts or updates a cache entry once the given future completes successfully.Constructor parameters in se.liu.ida.hefquin.federation.access.impl.cache.mapdb with type arguments of type DataRetrievalResponseModifierConstructorDescriptionMapDBCache(int capacity, String filename, CachePolicies<PersistentCacheKey, CompletableFuture<? extends DataRetrievalResponse<?>>, PersistentCacheEntry> policies) Creates a cache with the given capacity and file path.MapDBCache(int capacity, CachePolicies<PersistentCacheKey, CompletableFuture<? extends DataRetrievalResponse<?>>, PersistentCacheEntry> policies) Creates a cache with the given capacity and the default file path.MapDBCache(String filename, CachePolicies<PersistentCacheKey, CompletableFuture<? extends DataRetrievalResponse<?>>, PersistentCacheEntry> policies) Constructs a newMapDBCachewith a custom file path and the default cache capacity.MapDBCache(CachePolicies<PersistentCacheKey, CompletableFuture<? extends DataRetrievalResponse<?>>, PersistentCacheEntry> policies) Creates a cache with the default capacity and default file path. -
Uses of DataRetrievalResponse in se.liu.ida.hefquin.federation.access.impl.reqproc
Method parameters in se.liu.ida.hefquin.federation.access.impl.reqproc with type arguments of type DataRetrievalResponseModifier and TypeMethodDescriptiondefault booleanBRTPFRequestProcessor.isSupportedResponseType(Class<? extends DataRetrievalResponse<?>> t) default booleanJSONRetrievalProcessor.isSupportedResponseType(Class<? extends DataRetrievalResponse<?>> t) default booleanRESTRequestProcessor.isSupportedResponseType(Class<? extends DataRetrievalResponse<?>> t) default booleanSolMapRetrievalProcessor.isSupportedResponseType(Class<? extends DataRetrievalResponse<?>> t) default booleanStringRetrievalProcessor.isSupportedResponseType(Class<? extends DataRetrievalResponse<?>> t) default booleanTPFRequestProcessor.isSupportedResponseType(Class<? extends DataRetrievalResponse<?>> t) -
Uses of DataRetrievalResponse in se.liu.ida.hefquin.federation.access.impl.response
Classes in se.liu.ida.hefquin.federation.access.impl.response that implement DataRetrievalResponseModifier and TypeClassDescriptionclassclassclassclassclassclassclass