org.yamcs.yarch.rocksdb

Class RdbStorageEngine

java.lang.Object

org.yamcs.yarch.rocksdb.RdbStorageEngine

All Implemented Interfaces:

StorageEngine

public class RdbStorageEngine
extends Object
implements StorageEngine

Storage Engine based on RocksDB. Tables are mapped to multiple RocksDB databases - one for each time based partition. Value based partitions are mapped to column families.

Constructor Summary

Constructors

Constructor and Description
RdbStorageEngine(YarchDatabase ydb)
RdbStorageEngine(YarchDatabase ydb, boolean ignoreVersionIncompatibility)

Method Summary

Modifier and Type	Method and Description
void	createTable(TableDefinition def) Create a new table based on definition.
void	dropTable(TableDefinition tbl) Drop the table (removing all files)
Iterator<HistogramRecord>	getHistogramIterator(TableDefinition tblDef, String columnName, TimeInterval interval, long mergeTime)
static RdbStorageEngine	getInstance(YarchDatabase ydb)
RdbPartitionManager	getPartitionManager(TableDefinition tdef)
TagDb	getTagDb()
void	loadTable(TableDefinition tbl) Loads a table from the disk - called at startup.
AbstractStream	newTableReaderStream(TableDefinition tbl, boolean ascending, boolean follow) Creates a new table reader
TableWriter	newTableWriter(TableDefinition tblDef, TableWriter.InsertMode insertMode) Creates a new table writer
static void	removeInstance(YarchDatabase ydb) Called from unit tests to cleanup before the next test
void	setIgnoreVersionIncompatibility(boolean b) set to ignore version incompatibility - only used from the version upgrading functions to allow loading old tables.
void	shutdown() Called from Unit tests to cleanup before the next test

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RdbStorageEngine

public RdbStorageEngine(YarchDatabase ydb,
                        boolean ignoreVersionIncompatibility)
                 throws YarchException

Throws:

YarchException

RdbStorageEngine

public RdbStorageEngine(YarchDatabase ydb)
                 throws YarchException

Throws:

YarchException

Method Detail

loadTable

public void loadTable(TableDefinition tbl)
               throws YarchException

Description copied from interface: StorageEngine

Loads a table from the disk - called at startup.

Specified by:

loadTable in interface StorageEngine

Throws:

YarchException

dropTable

public void dropTable(TableDefinition tbl)
               throws YarchException

Description copied from interface: StorageEngine

Drop the table (removing all files)

Specified by:

dropTable in interface StorageEngine

Throws:

YarchException

newTableWriter

public TableWriter newTableWriter(TableDefinition tblDef,
                                  TableWriter.InsertMode insertMode)
                           throws YarchException

Description copied from interface: StorageEngine

Creates a new table writer

Specified by:

newTableWriter in interface StorageEngine

Returns:

Throws:

YarchException

newTableReaderStream

public AbstractStream newTableReaderStream(TableDefinition tbl,
                                           boolean ascending,
                                           boolean follow)

Description copied from interface: StorageEngine

Creates a new table reader

Specified by:

newTableReaderStream in interface StorageEngine

Returns:

createTable

public void createTable(TableDefinition def)

Description copied from interface: StorageEngine

Create a new table based on definition.

Specified by:

createTable in interface StorageEngine

getInstance

public static RdbStorageEngine getInstance(YarchDatabase ydb)

getPartitionManager

public RdbPartitionManager getPartitionManager(TableDefinition tdef)

getTagDb

public TagDb getTagDb()
               throws YarchException

Specified by:

getTagDb in interface StorageEngine

Throws:

YarchException

shutdown

public void shutdown()

Called from Unit tests to cleanup before the next test

removeInstance

public static void removeInstance(YarchDatabase ydb)

Called from unit tests to cleanup before the next test

Parameters:

ydb -

setIgnoreVersionIncompatibility

public void setIgnoreVersionIncompatibility(boolean b)

set to ignore version incompatibility - only used from the version upgrading functions to allow loading old tables.

Parameters:

b -

getHistogramIterator

public Iterator<HistogramRecord> getHistogramIterator(TableDefinition tblDef,
                                                      String columnName,
                                                      TimeInterval interval,
                                                      long mergeTime)
                                               throws YarchException

Specified by:

getHistogramIterator in interface StorageEngine

Throws:

YarchException