Uses of Class
org.yamcs.yarch.YarchDatabaseInstance
Package
Description
-
Uses of YarchDatabaseInstance in org.yamcs.archive
Modifier 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
Modifier and TypeMethodDescriptionstatic YarchDatabaseInstance
DatabaseApi.verifyDatabase
(String name) Modifier and TypeMethodDescriptionstatic Stream
TableApi.verifyStream
(Context ctx, YarchDatabaseInstance ydb, String streamName) -
Uses of YarchDatabaseInstance in org.yamcs.yarch
Modifier and TypeFieldDescriptionprotected final YarchDatabaseInstance
AbstractTableWalker.ydb
protected YarchDatabaseInstance
Stream.ydb
protected final YarchDatabaseInstance
TableWriter.ydb
Modifier and TypeMethodDescriptionExecutionContext.getDb()
static YarchDatabaseInstance
YarchDatabase.getInstance
(String yamcsInstance) Modifier 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) ModifierConstructorDescriptionHistogramReaderStream
(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
Modifier 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) ModifierConstructorDescriptionHistogramRebuilder
(Tablespace tablespace, YarchDatabaseInstance ydb, String tableName) RdbTableWriter
(YarchDatabaseInstance ydb, RdbTable table, TableWriter.InsertMode mode) -
Uses of YarchDatabaseInstance in org.yamcs.yarch.streamsql
Modifier 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.ModifierConstructorDescriptionprotected
LimitedStream
(YarchDatabaseInstance ydb, Stream input, BigDecimal offset, BigDecimal limit, TupleDefinition definition)