Q - the type of query that is being cachedpublic class LazyQueryCache<Q extends ReasonerQuery> extends Cache<Q,LazyAnswerIterator>
Lazy container class for storing performed query resolutions.
| Constructor and Description |
|---|
LazyQueryCache() |
| Modifier and Type | Method and Description |
|---|---|
long |
answerSize(Set<Q> queries) |
void |
consume() |
LazyAnswerIterator |
getAnswerIterator(Q query) |
LazyAnswerIterator |
getAnswers(Q query)
retrieve cached answers for provided query
|
java.util.stream.Stream<Answer> |
getAnswerStream(Q query) |
javafx.util.Pair<java.util.stream.Stream<Answer>,Unifier> |
getAnswerStreamWithUnifier(Q query) |
javafx.util.Pair<LazyAnswerIterator,Unifier> |
getAnswersWithUnifier(Q query) |
LazyAnswerIterator |
record(Q query,
LazyAnswerIterator answers)
record answer iterable for a specific query and retrieve the updated answers
|
java.util.stream.Stream<Answer> |
record(Q query,
java.util.stream.Stream<Answer> answers)
record answer stream for a specific query and retrieve the updated stream
|
LazyAnswerIterator |
recordRetrieveLazy(Q query,
java.util.stream.Stream<Answer> answers)
updates the cache by the specified query
|
void |
reload()
force stream consumption and reload cache
|
void |
remove(Cache<Q,LazyAnswerIterator> c2,
Set<Q> queries)
cache subtraction of specified queries
|
add, clear, contains, getInverseAnswerMap, getInverseAnswerMap, getQueries, removepublic LazyAnswerIterator record(Q query, LazyAnswerIterator answers)
Cacherecord in class Cache<Q extends ReasonerQuery,LazyAnswerIterator>query - to be recordedanswers - to this querypublic java.util.stream.Stream<Answer> record(Q query, java.util.stream.Stream<Answer> answers)
Cacherecord in class Cache<Q extends ReasonerQuery,LazyAnswerIterator>query - to be recordedanswers - answer stream of the querypublic LazyAnswerIterator recordRetrieveLazy(Q query, java.util.stream.Stream<Answer> answers)
recordRetrieveLazy in class Cache<Q extends ReasonerQuery,LazyAnswerIterator>query - query to be added/updatedanswers - answers to the querypublic LazyAnswerIterator getAnswers(Q query)
getAnswers in class Cache<Q extends ReasonerQuery,LazyAnswerIterator>query - for which to retrieve answerspublic javafx.util.Pair<LazyAnswerIterator,Unifier> getAnswersWithUnifier(Q query)
getAnswersWithUnifier in class Cache<Q extends ReasonerQuery,LazyAnswerIterator>public java.util.stream.Stream<Answer> getAnswerStream(Q query)
getAnswerStream in class Cache<Q extends ReasonerQuery,LazyAnswerIterator>public javafx.util.Pair<java.util.stream.Stream<Answer>,Unifier> getAnswerStreamWithUnifier(Q query)
getAnswerStreamWithUnifier in class Cache<Q extends ReasonerQuery,LazyAnswerIterator>public LazyAnswerIterator getAnswerIterator(Q query)
getAnswerIterator in class Cache<Q extends ReasonerQuery,LazyAnswerIterator>public long answerSize(Set<Q> queries)
answerSize in class Cache<Q extends ReasonerQuery,LazyAnswerIterator>public void remove(Cache<Q,LazyAnswerIterator> c2, Set<Q> queries)
Cacheremove in class Cache<Q extends ReasonerQuery,LazyAnswerIterator>c2 - subtraction right operandqueries - to which answers shall be subtractedpublic void reload()
public void consume()
Copyright © 2017 Grakn Labs Ltd. All rights reserved.