void |
YarchDatabaseInstance.addStream(Stream stream) |
Adds a stream to the dictionary making it "official"
|
void |
StorageEngine.createTable(YarchDatabaseInstance ydb,
TableDefinition tblDef) |
Create a new table based on definition.
|
void |
YarchDatabaseInstance.createTable(TableDefinition tbldef) |
add a table to the dictionary throws exception if a table or a stream with the same name already exist
|
void |
StorageEngine.dropTable(YarchDatabaseInstance ydb,
TableDefinition tblDef) |
Drop the table (removing all data)
|
Row |
TableDefinition.generateRow(Tuple t) |
Generate a new table row by transforming the key part of the tuple into a byte array to be written to
disk.
|
BucketDatabase |
StorageEngine.getBucketDatabase(YarchDatabaseInstance yarchDatabaseInstance) |
|
HistogramIterator |
StorageEngine.getHistogramIterator(YarchDatabaseInstance ydb,
TableDefinition tblDef,
String columnName,
TimeInterval interval) |
|
ProtobufDatabase |
StorageEngine.getProtobufDatabase(YarchDatabaseInstance ydb) |
|
ProtobufDatabase |
YarchDatabaseInstance.getProtobufDatabase() |
|
Sequence |
StorageEngine.getSequence(YarchDatabaseInstance ydb,
String name) |
Creates (if not already existing) and returns a sequence with the given name.
|
Sequence |
YarchDatabaseInstance.getSequence(String name) |
|
TagDb |
StorageEngine.getTagDb(YarchDatabaseInstance ydb) |
|
TagDb |
YarchDatabaseInstance.getTagDb() |
|
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/ /.def)
|
TableWriter |
StorageEngine.newTableWriter(YarchDatabaseInstance ydb,
TableDefinition tblDef,
TableWriter.InsertMode insertMode) |
Creates a new table writer
|
long |
Sequence.next() |
|
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)
|
protected abstract boolean |
AbstractTableWalker.walkInterval(PartitionManager.Interval interval,
DbRange range,
TableVisitor visitor) |
Runs the data in a time interval (corresponding to a time partition) sending data only that conform with the
start and end filters.
|