Package org.yamcs.yarch.rocksdb
Class RdbTableWalker
java.lang.Object
org.yamcs.yarch.AbstractTableWalker
org.yamcs.yarch.rocksdb.RdbTableWalker
- All Implemented Interfaces:
TableWalker
-
Field Summary
Fields inherited from class org.yamcs.yarch.AbstractTableWalker
ascending, ctx, follow, log, numRecordsRead, running, tableDefinition, ydb
-
Constructor Summary
ModifierConstructorDescriptionprotected
RdbTableWalker
(ExecutionContext ctx, TableDefinition tableDefinition, boolean ascending, boolean follow) -
Method Summary
Modifier and TypeMethodDescriptionlong
boolean
void
setBatchUpdates
(boolean batchUpdates) protected boolean
walkInterval
(PartitionManager.Interval interval, DbRange tableRange, TableVisitor visitor) Iterate data through the given interval taking into account also the tableRange.Methods inherited from class org.yamcs.yarch.AbstractTableWalker
close, iAscendingFinished, isDescendingFinished, isRunning, setPartitionFilter, setPrimaryIndexRange, walk
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.yamcs.yarch.TableWalker
setSecondaryIndexRange
-
Field Details
-
visitor
-
-
Constructor Details
-
RdbTableWalker
protected RdbTableWalker(ExecutionContext ctx, TableDefinition tableDefinition, boolean ascending, boolean follow)
-
-
Method Details
-
walkInterval
protected boolean walkInterval(PartitionManager.Interval interval, DbRange tableRange, TableVisitor visitor) throws YarchException, StreamSqlException Iterate data through the given interval taking into account also the tableRange.tableRange has to be non-null but can be unbounded at one or both ends. <p Return true if the tableRange is bounded and the end has been reached.
- Specified by:
walkInterval
in classAbstractTableWalker
- Returns:
- returns true if the end condition has been reached.
- Throws:
StreamSqlException
YarchException
-
getNumRecordsRead
public long getNumRecordsRead() -
isBatchUpdates
public boolean isBatchUpdates() -
setBatchUpdates
public void setBatchUpdates(boolean batchUpdates)
-