public abstract class StreamingInitialRoundIterator<T extends ReasonerTerm> extends Object implements StreamingIterator<T>
Modifier and Type | Field and Description |
---|---|
protected AtomManager |
atomManager |
protected boolean |
closed |
protected int |
currentRule |
protected T |
nextTerm |
protected int |
numPages |
static double |
OVERALLOCATION_RATIO |
protected int |
pageSize |
protected StreamingTermStore<T> |
parentStore |
protected List<GroundRule> |
pendingGroundRules |
protected QueryResultIterable |
queryIterable |
protected Iterator<Constant[]> |
queryResults |
protected List<WeightedRule> |
rules |
protected ByteBuffer |
termBuffer |
protected List<T> |
termCache |
protected int |
termCount |
protected HyperplaneTermGenerator<T,RandomVariableAtom> |
termGenerator |
protected List<T> |
termPool |
protected ByteBuffer |
volatileBuffer |
Constructor and Description |
---|
StreamingInitialRoundIterator(StreamingTermStore<T> parentStore,
List<WeightedRule> rules,
AtomManager atomManager,
HyperplaneTermGenerator<T,RandomVariableAtom> termGenerator,
List<T> termCache,
List<T> termPool,
ByteBuffer termBuffer,
ByteBuffer volatileBuffer,
int pageSize) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
boolean |
hasNext()
Get the next term.
|
T |
next() |
void |
remove() |
protected abstract void |
writeFullPage(String termPagePath,
String volatilePagePath)
Write a full page (including any volatile page that the child may use).
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEachRemaining
public static final double OVERALLOCATION_RATIO
protected StreamingTermStore<T extends ReasonerTerm> parentStore
protected HyperplaneTermGenerator<T extends ReasonerTerm,RandomVariableAtom> termGenerator
protected AtomManager atomManager
protected List<WeightedRule> rules
protected int currentRule
protected List<GroundRule> pendingGroundRules
protected List<T extends ReasonerTerm> termCache
protected List<T extends ReasonerTerm> termPool
protected ByteBuffer termBuffer
protected ByteBuffer volatileBuffer
protected int termCount
protected QueryResultIterable queryIterable
protected boolean closed
protected T extends ReasonerTerm nextTerm
protected int pageSize
protected int numPages
public StreamingInitialRoundIterator(StreamingTermStore<T> parentStore, List<WeightedRule> rules, AtomManager atomManager, HyperplaneTermGenerator<T,RandomVariableAtom> termGenerator, List<T> termCache, List<T> termPool, ByteBuffer termBuffer, ByteBuffer volatileBuffer, int pageSize)
public boolean hasNext()
hasNext
in interface Iterator<T extends ReasonerTerm>
public T next()
next
in interface Iterator<T extends ReasonerTerm>
public void remove()
remove
in interface Iterator<T extends ReasonerTerm>
public void close()
close
in interface StreamingIterator<T extends ReasonerTerm>
Copyright © 2020 University of California, Santa Cruz. All rights reserved.