public class SGDStreamingTermStore extends StreamingTermStore<SGDObjectiveTerm>
activeIterator, atomManager, CONFIG_PREFIX, INITIAL_PATH_CACHE_SIZE, initialRound, numPages, PAGE_LOCATION_DEFAULT, PAGE_LOCATION_KEY, PAGE_SIZE_DEFAULT, PAGE_SIZE_KEY, pageDir, pageSize, RANDOMIZE_PAGE_ACCESS_DEFAULT, RANDOMIZE_PAGE_ACCESS_KEY, randomizePageAccess, rules, seenTermCount, SHUFFLE_PAGE_DEFAULT, SHUFFLE_PAGE_KEY, shuffleMap, shufflePage, termBuffer, termCache, termGenerator, termPagePaths, termPool, variables, volatileBuffer, volatilePagePaths, WARN_RULES_DEFAULT, WARN_RULES_KEY, warnRules
Constructor and Description |
---|
SGDStreamingTermStore(List<Rule> rules,
AtomManager atomManager) |
Modifier and Type | Method and Description |
---|---|
protected StreamingIterator<SGDObjectiveTerm> |
getCacheIterator()
Get an iterator that will read and write from disk.
|
protected StreamingIterator<SGDObjectiveTerm> |
getInitialRoundIterator()
Get an iterator that will perform grounding queries and write the initial pages to disk.
|
protected StreamingIterator<SGDObjectiveTerm> |
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, getVariableValues, getVolatilePagePath, initialIterationComplete, isLoaded, iterator, noWriteIterator, size, syncAtoms
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEach, spliterator
public SGDStreamingTermStore(List<Rule> rules, AtomManager atomManager)
protected boolean supportsRule(Rule rule)
StreamingTermStore
supportsRule
in class StreamingTermStore<SGDObjectiveTerm>
protected StreamingIterator<SGDObjectiveTerm> getInitialRoundIterator()
StreamingTermStore
getInitialRoundIterator
in class StreamingTermStore<SGDObjectiveTerm>
protected StreamingIterator<SGDObjectiveTerm> getCacheIterator()
StreamingTermStore
getCacheIterator
in class StreamingTermStore<SGDObjectiveTerm>
protected StreamingIterator<SGDObjectiveTerm> getNoWriteIterator()
StreamingTermStore
getNoWriteIterator
in class StreamingTermStore<SGDObjectiveTerm>
Copyright © 2020 University of California, Santa Cruz. All rights reserved.