ai.grakn.graql.internal.reasoner.cache

Interface QueryCache<Q extends ReasonerQueryImpl,S extends Iterable<ConceptMap>>

Type Parameters:

Q - the type of query that is being cached

S - the type of answer being cached

All Known Implementing Classes:

LazyQueryCache, QueryCacheBase, SimpleQueryCache

public interface QueryCache<Q extends ReasonerQueryImpl,S extends Iterable<ConceptMap>>

Generic interface query caches. Defines two basic operations: - GET(Query) - RECORD(Query, Answer).

Author:

Kasper Piskorski

Method Summary

Modifier and Type	Method and Description
void	clear() Clear the cache
boolean	contains(Q query) Query cache containment check
S	getAnswers(Q query) retrieve (possibly) cached answers for provided query
java.util.stream.Stream<ConceptMap>	getAnswerStream(Q query)
Set<Q>	getQueries()
void	merge(QueryCacheBase<Q,S> c2) Perform cache union
ConceptMap	record(Q query, ConceptMap answer) record single answer to a specific query
S	record(Q query, S answers) record answer iterable for a specific query and retrieve the updated answers
java.util.stream.Stream<ConceptMap>	record(Q query, java.util.stream.Stream<ConceptMap> answers) record answer stream for a specific query and retrieve the updated stream

Method Detail

record

S record(Q query,
         S answers)

record answer iterable for a specific query and retrieve the updated answers

Parameters:

query - to be recorded

answers - to this query

Returns:

updated answer iterable

record

java.util.stream.Stream<ConceptMap> record(Q query,
                                           java.util.stream.Stream<ConceptMap> answers)

record answer stream for a specific query and retrieve the updated stream

Parameters:

query - to be recorded

answers - answer stream of the query

Returns:

updated answer stream

record

ConceptMap record(Q query,
                  ConceptMap answer)

record single answer to a specific query

Parameters:

query - of interest

answer - to this query

Returns:

recorded answer

getAnswers

S getAnswers(Q query)

retrieve (possibly) cached answers for provided query

Parameters:

query - for which to retrieve answers

Returns:

unified cached answers

getAnswerStream

java.util.stream.Stream<ConceptMap> getAnswerStream(Q query)

contains

boolean contains(Q query)

Query cache containment check

Parameters:

query - to be checked for containment

Returns:

true if cache contains the query

getQueries

Set<Q> getQueries()

Returns:

all queries contained in this cache

merge

void merge(QueryCacheBase<Q,S> c2)

Perform cache union

Parameters:

c2 - union right operand

clear

void clear()

Clear the cache