Uses of Class
org.yamcs.yarch.YarchDatabaseInstance

Packages that use YarchDatabaseInstance

Package	Description
org.yamcs.archive
org.yamcs.http.api
org.yamcs.yarch
org.yamcs.yarch.rocksdb
org.yamcs.yarch.streamsql

Uses of YarchDatabaseInstance in org.yamcs.archive

Methods in org.yamcs.archive with parameters of type YarchDatabaseInstance

Modifier and Type	Method	Description
static void	Utils.closeTableWriters(YarchDatabaseInstance ydb, Collection<String> streamNames)	close all table writers subscribed to any of the stream in the list

Uses of YarchDatabaseInstance in org.yamcs.http.api

Methods in org.yamcs.http.api that return YarchDatabaseInstance

Modifier and Type	Method	Description
static YarchDatabaseInstance	DatabaseApi.verifyDatabase(String name)

Methods in org.yamcs.http.api with parameters of type YarchDatabaseInstance

Modifier and Type	Method	Description
static Stream	TableApi.verifyStream(Context ctx, YarchDatabaseInstance ydb, String streamName)

Uses of YarchDatabaseInstance in org.yamcs.yarch

Fields in org.yamcs.yarch declared as YarchDatabaseInstance

Modifier and Type	Field	Description
protected final YarchDatabaseInstance	AbstractTableWalker.ydb
protected YarchDatabaseInstance	Stream.ydb
protected final YarchDatabaseInstance	TableWriter.ydb

Methods in org.yamcs.yarch that return YarchDatabaseInstance

Modifier and Type	Method	Description
YarchDatabaseInstance	ExecutionContext.getDb()
static YarchDatabaseInstance	YarchDatabase.getInstance(String yamcsInstance)

Methods in org.yamcs.yarch with parameters of type YarchDatabaseInstance

Modifier and Type	Method	Description
void	StorageEngine.createTable(YarchDatabaseInstance ydb, TableDefinition tblDef)	Create a new table based on definition.
void	StorageEngine.dropTable(YarchDatabaseInstance ydb, TableDefinition tblDef)	Drop the table (removing all data)
BucketDatabase	StorageEngine.getBucketDatabase(YarchDatabaseInstance yarchDatabaseInstance)
HistogramIterator	StorageEngine.getHistogramIterator(YarchDatabaseInstance ydb, TableDefinition tblDef, String columnName, TimeInterval interval)
PartitionManager	StorageEngine.getPartitionManager(YarchDatabaseInstance ydb, TableDefinition tblDef)
ProtobufDatabase	StorageEngine.getProtobufDatabase(YarchDatabaseInstance ydb)
Sequence	StorageEngine.getSequence(YarchDatabaseInstance ydb, String name, boolean create)	Returns a sequence with the given name if it exists or first create it and returns it if create is true.
List<SequenceInfo>	StorageEngine.getSequencesInfo(YarchDatabaseInstance ydb)	Gets the list of sequences togehter with their latest values
List<TableDefinition>	StorageEngine.loadTables(YarchDatabaseInstance ydb)	Loads the table definitions from the disk for all the tables belonging to the instance.
default void	StorageEngine.migrateTableDefinition(YarchDatabaseInstance ydb, TableDefinition tblDef)	In Yamcs version 4 the table definitions were stored in yaml serialized format (in the /storage/yamcs-data/<instance-name>/<table-name>.def)
TableWalker	StorageEngine.newSecondaryIndexTableWalker(YarchDatabaseInstance ydb, TableDefinition tableDefinition, boolean ascending, boolean follow)
TableWriter	StorageEngine.newTableWriter(YarchDatabaseInstance ydb, TableDefinition tblDef, TableWriter.InsertMode insertMode)	Creates a new table writer
void	StorageEngine.renameTable(YarchDatabaseInstance ydb, TableDefinition tblDef, String newName)	rename the table
void	StorageEngine.saveTableDefinition(YarchDatabaseInstance ydb, TableDefinition tblDef, List<TableColumnDefinition> keyColumns, List<TableColumnDefinition> valueColumns)	Persist the table definition to diks (called when the table definition modifies)
void	TableDefinition.setDb(YarchDatabaseInstance ydb)

Constructors in org.yamcs.yarch with parameters of type YarchDatabaseInstance

Modifier	Constructor	Description
	ExecutionContext(YarchDatabaseInstance db)
	HistogramReaderStream(YarchDatabaseInstance ydb, TableDefinition tblDef, String histoColumnName, TupleDefinition tupleDef)
	MergeStream(YarchDatabaseInstance ydb, Stream[] streams, String mergeColumn, boolean ascending)
	OutputStream(YarchDatabaseInstance dict, String name, TupleDefinition def)
	SelectStream(YarchDatabaseInstance ydb, Stream input, CompiledExpression cWhereClause, List<CompiledExpression> caggInputList, WindowProcessor wp, List<CompiledExpression> cselectList, TupleDefinition outputDef, TupleDefinition minOutputDef)
protected	Stream(YarchDatabaseInstance ydb, String name, TupleDefinition definition)
	TableReaderStream(YarchDatabaseInstance ydb, TableDefinition tblDef, TableWalker iterator)
	TableWriter(YarchDatabaseInstance ydb, Table table, TableWriter.InsertMode mode)

Uses of YarchDatabaseInstance in org.yamcs.yarch.rocksdb

Methods in org.yamcs.yarch.rocksdb with parameters of type YarchDatabaseInstance

Modifier and Type	Method	Description
void	RdbStorageEngine.createTable(YarchDatabaseInstance ydb, TableDefinition def)
void	RdbStorageEngine.dropTable(YarchDatabaseInstance ydb, TableDefinition tbl)
BucketDatabase	RdbStorageEngine.getBucketDatabase(YarchDatabaseInstance ydb)
HistogramIterator	RdbStorageEngine.getHistogramIterator(YarchDatabaseInstance ydb, TableDefinition tblDef, String columnName, TimeInterval interval)
RdbPartitionManager	RdbStorageEngine.getPartitionManager(YarchDatabaseInstance ydb, TableDefinition tblDef)
ProtobufDatabase	RdbStorageEngine.getProtobufDatabase(YarchDatabaseInstance ydb)
Sequence	RdbStorageEngine.getSequence(YarchDatabaseInstance ydb, String name, boolean create)
List<SequenceInfo>	RdbStorageEngine.getSequencesInfo(YarchDatabaseInstance ydb)
Tablespace	RdbStorageEngine.getTablespace(YarchDatabaseInstance ydb)	Create and/or get the tablespace for the yarch database instance.
List<TableDefinition>	RdbStorageEngine.loadTables(YarchDatabaseInstance ydb)
void	RdbStorageEngine.migrateTableDefinition(YarchDatabaseInstance ydb, TableDefinition tblDef)
TableWalker	RdbStorageEngine.newSecondaryIndexTableWalker(YarchDatabaseInstance ydb, TableDefinition tableDefinition, boolean ascending, boolean follow)
TableWalker	Tablespace.newSecondaryIndexTableWalker(YarchDatabaseInstance ydb, TableDefinition tblDef, boolean ascending, boolean follow)
RdbTableWriter	RdbStorageEngine.newTableWriter(YarchDatabaseInstance ydb, TableDefinition tblDef, TableWriter.InsertMode insertMode)
RdbTableWriter	Tablespace.newTableWriter(YarchDatabaseInstance ydb, TableDefinition tblDef, TableWriter.InsertMode insertMode)
void	RdbStorageEngine.renameTable(YarchDatabaseInstance ydb, TableDefinition tblDef, String newName)
void	RdbStorageEngine.saveTableDefinition(YarchDatabaseInstance ydb, TableDefinition tblDef, List<TableColumnDefinition> keyColumns, List<TableColumnDefinition> valueColumns)

Constructors in org.yamcs.yarch.rocksdb with parameters of type YarchDatabaseInstance

Modifier	Constructor	Description
	HistogramRebuilder(Tablespace tablespace, YarchDatabaseInstance ydb, String tableName)
	RdbTableWriter(YarchDatabaseInstance ydb, RdbTable table, TableWriter.InsertMode mode)

Uses of YarchDatabaseInstance in org.yamcs.yarch.streamsql

Methods in org.yamcs.yarch.streamsql with parameters of type YarchDatabaseInstance

Modifier and Type	Method	Description
StreamSqlResult	SelectTableStatement.execute(YarchDatabaseInstance ydb)
void	SelectTableStatement.execute(YarchDatabaseInstance ydb, ResultListener resultListener, long limit)
StreamSqlResult	SimpleStreamSqlStatement.execute(YarchDatabaseInstance ydb)
void	SimpleStreamSqlStatement.execute(YarchDatabaseInstance ydb, ResultListener resultListener, long limit)
StreamSqlResult	StreamSqlStatement.execute(YarchDatabaseInstance ydb)	Execute query and return a result.
default void	StreamSqlStatement.execute(YarchDatabaseInstance ydb, ResultListener resultListener)	Execute query and send the results to the result listener.
void	StreamSqlStatement.execute(YarchDatabaseInstance ydb, ResultListener resultListener, long limit)	Execute query and limit the number of results returned.

Constructors in org.yamcs.yarch.streamsql with parameters of type YarchDatabaseInstance

Modifier	Constructor	Description
protected	LimitedStream(YarchDatabaseInstance ydb, Stream input, BigDecimal offset, BigDecimal limit, TupleDefinition definition)