org.yamcs.yarch

Interface StorageEngine

All Known Implementing Classes:

RdbStorageEngine

public interface StorageEngine

Method Summary

Modifier and Type	Method and Description
void	createTable(TableDefinition def) Create a new table based on definition.
void	dropTable(TableDefinition tbldef) Drop the table (removing all files)
Iterator<HistogramRecord>	getHistogramIterator(TableDefinition tblDef, String columnName, TimeInterval interval, long mergeTime)
TagDb	getTagDb()
void	loadTable(TableDefinition tbl) Loads a table from the disk - called at startup.
AbstractStream	newTableReaderStream(TableDefinition tbl, boolean ascending, boolean follow) Creates a new table reader
TableWriter	newTableWriter(TableDefinition tbl, TableWriter.InsertMode insertMode) Creates a new table writer

Method Detail

createTable

void createTable(TableDefinition def)
          throws YarchException

Create a new table based on definition.

Parameters:

def -

Throws:

YarchException

dropTable

void dropTable(TableDefinition tbldef)
        throws YarchException

Drop the table (removing all files)

Parameters:

tbldef -

Throws:

YarchException

loadTable

void loadTable(TableDefinition tbl)
        throws YarchException

Loads a table from the disk - called at startup.

Parameters:

tbl -

Throws:

YarchException

newTableWriter

TableWriter newTableWriter(TableDefinition tbl,
                           TableWriter.InsertMode insertMode)
                    throws YarchException

Creates a new table writer

Parameters:

tbl -

insertMode -

Returns:

Throws:

YarchException

newTableReaderStream

AbstractStream newTableReaderStream(TableDefinition tbl,
                                    boolean ascending,
                                    boolean follow)

Creates a new table reader

Parameters:

tbl -

Returns:

getTagDb

TagDb getTagDb()
        throws YarchException

Throws:

YarchException

getHistogramIterator

Iterator<HistogramRecord> getHistogramIterator(TableDefinition tblDef,
                                               String columnName,
                                               TimeInterval interval,
                                               long mergeTime)
                                        throws YarchException

Throws:

YarchException