ai.grakn.graql.internal.reasoner.cache

Class SimpleQueryCache<Q extends ReasonerQueryImpl>

java.lang.Object

ai.grakn.graql.internal.reasoner.cache.QueryCacheBase<Q,QueryAnswers>

ai.grakn.graql.internal.reasoner.cache.SimpleQueryCache<Q>

Type Parameters:

Q - the type of query that is being cached

All Implemented Interfaces:

QueryCache<Q,QueryAnswers>

public class SimpleQueryCache<Q extends ReasonerQueryImpl>
extends QueryCacheBase<Q,QueryAnswers>

Container class for storing performed query resolutions. Cache operations are handled in the following way: - GET(Query) - retrieve an entry corresponding to a provided query, if entry doesn't exist return db lookup result of the query. - RECORD(Query) - if the query entry exists, update the entry, otherwise create a new entry. In each case return an up-to-date entry.

Author:

Kasper Piskorski

Constructor Summary

Constructors

Constructor and Description
SimpleQueryCache()

Method Summary

Modifier and Type	Method and Description
ConceptMap	getAnswer(Q query, ConceptMap ans) find specific answer to a query in the cache
QueryAnswers	getAnswers(Q query) retrieve (possibly) cached answers for provided query
java.util.stream.Stream<ConceptMap>	getAnswerStream(Q query)
Pair<java.util.stream.Stream<ConceptMap>,MultiUnifier>	getAnswerStreamWithUnifier(Q query)
Pair<QueryAnswers,MultiUnifier>	getAnswersWithUnifier(Q query)
ConceptMap	record(Q query, ConceptMap answer) record a specific answer to a given query
ConceptMap	record(Q query, ConceptMap answer, MultiUnifier unifier) record a specific answer to a given query with a known cache unifier
QueryAnswers	record(Q query, QueryAnswers 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> answerStream) record answer stream for a specific query and retrieve the updated stream

Methods inherited from class ai.grakn.graql.internal.reasoner.cache.QueryCacheBase

clear, contains, getQueries, merge, ruleCache

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleQueryCache

public SimpleQueryCache()

Method Detail

record

public QueryAnswers record(Q query,
                           QueryAnswers answers)

Description copied from interface: QueryCache

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

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

Description copied from interface: QueryCache

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

Parameters:

query - to be recorded

answerStream - answer stream of the query

Returns:

updated answer stream

record

public ConceptMap record(Q query,
                         ConceptMap answer)

record a specific answer to a given query

Parameters:

query - to which an answer is to be recorded

answer - specific answer to the query

Returns:

recorded answer

record

public ConceptMap record(Q query,
                         ConceptMap answer,
                         @Nullable
                         MultiUnifier unifier)

record a specific answer to a given query with a known cache unifier

Parameters:

query - to which an answer is to be recorded

answer - answer specific answer to the query

unifier - between the cached and input query

Returns:

recorded answer

getAnswers

public QueryAnswers getAnswers(Q query)

Description copied from interface: QueryCache

retrieve (possibly) cached answers for provided query

Parameters:

query - for which to retrieve answers

Returns:

unified cached answers

getAnswerStream

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

getAnswersWithUnifier

public Pair<QueryAnswers,MultiUnifier> getAnswersWithUnifier(Q query)

Specified by:

getAnswersWithUnifier in class QueryCacheBase<Q extends ReasonerQueryImpl,QueryAnswers>

getAnswerStreamWithUnifier

public Pair<java.util.stream.Stream<ConceptMap>,MultiUnifier> getAnswerStreamWithUnifier(Q query)

Specified by:

getAnswerStreamWithUnifier in class QueryCacheBase<Q extends ReasonerQueryImpl,QueryAnswers>

getAnswer

public ConceptMap getAnswer(Q query,
                            ConceptMap ans)

find specific answer to a query in the cache

Parameters:

query - input query

ans - sought specific answer to the query

Returns:

found answer if any, otherwise empty answer