ai.grakn.graql.internal.reasoner.cache

Class LazyQueryCache<Q extends ReasonerQueryImpl>

java.lang.Object

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

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

Type Parameters:

Q - the type of query that is being cached

All Implemented Interfaces:

QueryCache<Q,LazyAnswerIterator>

public class LazyQueryCache<Q extends ReasonerQueryImpl>
extends QueryCacheBase<Q,LazyAnswerIterator>

Lazy container class for storing performed query resolutions. NB: For the GET operation, in the case the entry is not found, a RECORD operation is performed.

Author:

Kasper Piskorski

Constructor Summary

Constructors

Constructor and Description
LazyQueryCache()

Method Summary

Modifier and Type	Method and Description
LazyAnswerIterator	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<LazyAnswerIterator,MultiUnifier>	getAnswersWithUnifier(Q query)
ConceptMap	record(Q query, ConceptMap answer) record single answer to a specific query
LazyAnswerIterator	record(Q query, LazyAnswerIterator 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
LazyAnswerIterator	recordRetrieveLazy(Q query, java.util.stream.Stream<ConceptMap> answers) record answer stream for a specific query and retrieve the updated stream in a lazy iterator

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

LazyQueryCache

public LazyQueryCache()

Method Detail

record

public ConceptMap record(Q query,
                         ConceptMap answer)

Description copied from interface: QueryCache

record single answer to a specific query

Parameters:

query - of interest

answer - to this query

Returns:

recorded answer

record

public LazyAnswerIterator record(Q query,
                                 LazyAnswerIterator 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> answers)

Description copied from interface: QueryCache

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

recordRetrieveLazy

public LazyAnswerIterator recordRetrieveLazy(Q query,
                                             java.util.stream.Stream<ConceptMap> answers)

record answer stream for a specific query and retrieve the updated stream in a lazy iterator

Parameters:

query - to be recorded

answers - answer stream of the query

Returns:

lazy iterator of updated answers

getAnswers

public LazyAnswerIterator 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<LazyAnswerIterator,MultiUnifier> getAnswersWithUnifier(Q query)

Specified by:

getAnswersWithUnifier in class QueryCacheBase<Q extends ReasonerQueryImpl,LazyAnswerIterator>

getAnswerStreamWithUnifier

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

Specified by:

getAnswerStreamWithUnifier in class QueryCacheBase<Q extends ReasonerQueryImpl,LazyAnswerIterator>