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. Data is stored in multiple Tablespace

Field Summary

Fields

Modifier and Type	Field and Description
static int	TBS_INDEX_SIZE

Method Summary

Modifier and Type	Method and Description
void	createTable(YarchDatabaseInstance ydb, TableDefinition def) Create a new table based on definition.
Tablespace	createTablespace(String tablespaceName)
void	dropTable(YarchDatabaseInstance ydb, TableDefinition tbl) Drop the table (removing all files)
void	dropTablespace(String tablespaceName)
HistogramIterator	getHistogramIterator(YarchDatabaseInstance ydb, TableDefinition tblDef, String columnName, TimeInterval interval, long mergeTime)
static RdbStorageEngine	getInstance()
RdbPartitionManager	getPartitionManager(TableDefinition tdef)
Tablespace	getTablespace(String tablespaceName)
Map<String,Tablespace>	getTablespaces()
TagDb	getTagDb(YarchDatabaseInstance ydb)
void	loadTable(YarchDatabaseInstance ydb, TableDefinition tblDef) Loads a table from the disk - called at startup.
void	loadTablespaces(boolean readOnly)
AbstractStream	newTableReaderStream(YarchDatabaseInstance ydb, TableDefinition tbl, boolean ascending, boolean follow) Creates a new table reader
TableWriter	newTableWriter(YarchDatabaseInstance ydb, TableDefinition tblDef, TableWriter.InsertMode insertMode) Creates a new table writer
void	setIgnoreVersionIncompatibility(boolean b) set to ignore version incompatibility - only used from the version upgrading functions to allow loading old tables.
void	shutdown()

Methods inherited from class java.lang.Object

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

Field Detail

TBS_INDEX_SIZE

public static final int TBS_INDEX_SIZE

See Also:

Constant Field Values

Method Detail

loadTablespaces

public void loadTablespaces(boolean readOnly)
                     throws YarchException

Throws:

YarchException

loadTable

public void loadTable(YarchDatabaseInstance ydb,
                      TableDefinition tblDef)
               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(YarchDatabaseInstance ydb,
                      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(YarchDatabaseInstance ydb,
                                  TableDefinition tblDef,
                                  TableWriter.InsertMode insertMode)

Description copied from interface: StorageEngine

Creates a new table writer

Specified by:

newTableWriter in interface StorageEngine

Returns:

newTableReaderStream

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

Description copied from interface: StorageEngine

Creates a new table reader

Specified by:

newTableReaderStream in interface StorageEngine

createTable

public void createTable(YarchDatabaseInstance ydb,
                        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()

getPartitionManager

public RdbPartitionManager getPartitionManager(TableDefinition tdef)

getTagDb

public TagDb getTagDb(YarchDatabaseInstance ydb)
               throws YarchException

Specified by:

getTagDb in interface StorageEngine

Throws:

YarchException

getTablespaces

public Map<String,Tablespace> getTablespaces()

createTablespace

public Tablespace createTablespace(String tablespaceName)

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 HistogramIterator getHistogramIterator(YarchDatabaseInstance ydb,
                                              TableDefinition tblDef,
                                              String columnName,
                                              TimeInterval interval,
                                              long mergeTime)
                                       throws YarchException

Specified by:

getHistogramIterator in interface StorageEngine

Throws:

YarchException

getTablespace

public Tablespace getTablespace(String tablespaceName)

dropTablespace

public void dropTablespace(String tablespaceName)

shutdown

public void shutdown()