public class DCDStreamingTermStore extends StreamingTermStore<DCDObjectiveTerm>
activeIterator, atomManager, INITIAL_PATH_CACHE_SIZE, initialRound, numPages, pageDir, pageSize, randomizePageAccess, rules, seenTermCount, shuffleMap, shufflePage, termBuffer, termCache, termGenerator, termPagePaths, termPool, variables, volatileBuffer, volatilePagePaths, warnRules
Constructor and Description |
---|
DCDStreamingTermStore(List<Rule> rules,
AtomManager atomManager) |
Modifier and Type | Method and Description |
---|---|
protected StreamingIterator<DCDObjectiveTerm> |
getCacheIterator()
Get an iterator that will read and write from disk.
|
protected StreamingIterator<DCDObjectiveTerm> |
getInitialRoundIterator()
Get an iterator that will perform grounding queries and write the initial pages to disk.
|
protected StreamingIterator<DCDObjectiveTerm> |
getNoWriteIterator()
Get an iterator that will not write to disk.
|
protected boolean |
supportsRule(Rule rule)
Check if this term store supports this rule.
|
add, cacheIterationComplete, clear, close, createLocalVariable, ensureCapacity, ensureVariableCapacity, get, getNumVariables, getTermPagePath, getVariableIndex, getVariables, getVariableValue, getVariableValues, getVolatilePagePath, initForOptimization, initialIterationComplete, isLoaded, iterationComplete, iterator, noWriteIterator, reset, size, syncAtoms, updateVariableValue
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEach, spliterator
public DCDStreamingTermStore(List<Rule> rules, AtomManager atomManager)
protected boolean supportsRule(Rule rule)
StreamingTermStore
supportsRule
in class StreamingTermStore<DCDObjectiveTerm>
protected StreamingIterator<DCDObjectiveTerm> getInitialRoundIterator()
StreamingTermStore
getInitialRoundIterator
in class StreamingTermStore<DCDObjectiveTerm>
protected StreamingIterator<DCDObjectiveTerm> getCacheIterator()
StreamingTermStore
getCacheIterator
in class StreamingTermStore<DCDObjectiveTerm>
protected StreamingIterator<DCDObjectiveTerm> getNoWriteIterator()
StreamingTermStore
getNoWriteIterator
in class StreamingTermStore<DCDObjectiveTerm>
Copyright © 2020 University of California, Santa Cruz. All rights reserved.