Class RdbTableWalker

java.lang.Object
org.yamcs.yarch.AbstractTableWalker
org.yamcs.yarch.rocksdb.RdbTableWalker
All Implemented Interfaces:
TableWalker

public class RdbTableWalker extends AbstractTableWalker
  • Field Details

  • Constructor Details

  • 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 class AbstractTableWalker
      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)