Uses of Class
org.yamcs.yarch.YarchDatabaseInstance
Packages that use YarchDatabaseInstance
Package
Description
-
Uses of YarchDatabaseInstance in org.yamcs.archive
Methods in org.yamcs.archive with parameters of type YarchDatabaseInstanceModifier and TypeMethodDescriptionstatic 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 YarchDatabaseInstanceModifier and TypeMethodDescriptionstatic YarchDatabaseInstance
DatabaseApi.verifyDatabase
(String name) Methods in org.yamcs.http.api with parameters of type YarchDatabaseInstanceModifier and TypeMethodDescriptionstatic Stream
TableApi.verifyStream
(Context ctx, YarchDatabaseInstance ydb, String streamName) -
Uses of YarchDatabaseInstance in org.yamcs.yarch
Fields in org.yamcs.yarch declared as YarchDatabaseInstanceModifier and TypeFieldDescriptionprotected final YarchDatabaseInstance
AbstractTableWalker.ydb
protected YarchDatabaseInstance
Stream.ydb
protected final YarchDatabaseInstance
TableWriter.ydb
Methods in org.yamcs.yarch that return YarchDatabaseInstanceModifier and TypeMethodDescriptionExecutionContext.getDb()
static YarchDatabaseInstance
YarchDatabase.getInstance
(String yamcsInstance) Methods in org.yamcs.yarch with parameters of type YarchDatabaseInstanceModifier and TypeMethodDescriptionvoid
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)StorageEngine.getBucketDatabase
(YarchDatabaseInstance yarchDatabaseInstance) StorageEngine.getHistogramIterator
(YarchDatabaseInstance ydb, TableDefinition tblDef, String columnName, TimeInterval interval) StorageEngine.getPartitionManager
(YarchDatabaseInstance ydb, TableDefinition tblDef) StorageEngine.getProtobufDatabase
(YarchDatabaseInstance ydb) 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.StorageEngine.getSequencesInfo
(YarchDatabaseInstance ydb) Gets the list of sequences togehter with their latest valuesStorageEngine.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)StorageEngine.newSecondaryIndexTableWalker
(YarchDatabaseInstance ydb, TableDefinition tableDefinition, boolean ascending, boolean follow) StorageEngine.newTableWriter
(YarchDatabaseInstance ydb, TableDefinition tblDef, TableWriter.InsertMode insertMode) Creates a new table writervoid
StorageEngine.renameTable
(YarchDatabaseInstance ydb, TableDefinition tblDef, String newName) rename the tablevoid
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 YarchDatabaseInstanceModifierConstructorDescriptionHistogramReaderStream
(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 YarchDatabaseInstanceModifier and TypeMethodDescriptionvoid
RdbStorageEngine.createTable
(YarchDatabaseInstance ydb, TableDefinition def) void
RdbStorageEngine.dropTable
(YarchDatabaseInstance ydb, TableDefinition tbl) RdbStorageEngine.getBucketDatabase
(YarchDatabaseInstance ydb) RdbStorageEngine.getHistogramIterator
(YarchDatabaseInstance ydb, TableDefinition tblDef, String columnName, TimeInterval interval) RdbStorageEngine.getPartitionManager
(YarchDatabaseInstance ydb, TableDefinition tblDef) RdbStorageEngine.getProtobufDatabase
(YarchDatabaseInstance ydb) RdbStorageEngine.getSequence
(YarchDatabaseInstance ydb, String name, boolean create) RdbStorageEngine.getSequencesInfo
(YarchDatabaseInstance ydb) RdbStorageEngine.getTablespace
(YarchDatabaseInstance ydb) Create and/or get the tablespace for the yarch database instance.RdbStorageEngine.loadTables
(YarchDatabaseInstance ydb) void
RdbStorageEngine.migrateTableDefinition
(YarchDatabaseInstance ydb, TableDefinition tblDef) RdbStorageEngine.newSecondaryIndexTableWalker
(YarchDatabaseInstance ydb, TableDefinition tableDefinition, boolean ascending, boolean follow) Tablespace.newSecondaryIndexTableWalker
(YarchDatabaseInstance ydb, TableDefinition tblDef, boolean ascending, boolean follow) RdbStorageEngine.newTableWriter
(YarchDatabaseInstance ydb, TableDefinition tblDef, TableWriter.InsertMode insertMode) 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 YarchDatabaseInstanceModifierConstructorDescriptionHistogramRebuilder
(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 YarchDatabaseInstanceModifier and TypeMethodDescriptionSelectTableStatement.execute
(YarchDatabaseInstance ydb) void
SelectTableStatement.execute
(YarchDatabaseInstance ydb, ResultListener resultListener, long limit) SimpleStreamSqlStatement.execute
(YarchDatabaseInstance ydb) void
SimpleStreamSqlStatement.execute
(YarchDatabaseInstance ydb, ResultListener resultListener, long limit) 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 YarchDatabaseInstanceModifierConstructorDescriptionprotected
LimitedStream
(YarchDatabaseInstance ydb, Stream input, BigDecimal offset, BigDecimal limit, TupleDefinition definition)