Package org.yamcs.yarch.rocksdb

Class SecondaryIndexTableWalker

java.lang.Object

org.yamcs.yarch.rocksdb.SecondaryIndexTableWalker

All Implemented Interfaces:

TableWalker

public class SecondaryIndexTableWalker
extends Object
implements TableWalker

iterates through a table based on the secondary index range.

The Rocksdb key of the secondary index is formed by

• tbsIndex
• secondary key
• primary key

Field Summary

Fields

Modifier and Type	Field	Description
protected TableVisitor	visitor

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	SecondaryIndexTableWalker(Tablespace tablespace, RdbTable table, boolean ascending, boolean follow)

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	isBatchUpdates()
void	setBatchUpdates(boolean batchUpdates)
void	setPrimaryIndexRange(DbRange pkRange)
void	setSecondaryIndexRange(DbRange skRange)
void	walk(TableVisitor visitor)	Iterate data through the given interval taking into account also the tableRange.

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

setPartitionFilter

Field Details

visitor

protected TableVisitor visitor

Constructor Details

SecondaryIndexTableWalker

protected SecondaryIndexTableWalker(Tablespace tablespace,
 RdbTable table,
 boolean ascending,
 boolean follow)

Method Details

walk

public void walk(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.

Return true if the tableRange is bounded and the end has been reached.

Specified by:

walk in interface TableWalker

Throws:

StreamSqlException

YarchException

setPrimaryIndexRange

public void setPrimaryIndexRange(DbRange pkRange)

Specified by:

setPrimaryIndexRange in interface TableWalker

setSecondaryIndexRange

public void setSecondaryIndexRange(DbRange skRange)

Specified by:

setSecondaryIndexRange in interface TableWalker

close

public void close()

Specified by:

close in interface TableWalker

isBatchUpdates

public boolean isBatchUpdates()

Specified by:

isBatchUpdates in interface TableWalker

setBatchUpdates

public void setBatchUpdates(boolean batchUpdates)

Specified by:

setBatchUpdates in interface TableWalker