org.yamcs.yarch.rocksdb

Class AbstractTableWriter

java.lang.Object

org.yamcs.yarch.TableWriter

org.yamcs.yarch.rocksdb.AbstractTableWriter

All Implemented Interfaces:

StreamSubscriber

Direct Known Subclasses:

CfTableWriter, InKeyTableWriter

public abstract class AbstractTableWriter
extends TableWriter

Nested Class Summary

Nested classes/interfaces inherited from class org.yamcs.yarch.TableWriter

TableWriter.InsertMode

Field Summary

Fields inherited from class org.yamcs.yarch.TableWriter

mode, tableDefinition, ydb

Constructor Summary

Constructors

Constructor and Description
AbstractTableWriter(YarchDatabase ydb, TableDefinition tableDefinition, TableWriter.InsertMode mode)

Method Summary

Modifier and Type	Method and Description
protected void	addHistogram(YRDB db, Tuple t)
abstract RdbPartition	getDbPartition(Tuple tuple)
static String	getHistogramColumnFamilyName(String tableColumnName)

Methods inherited from class org.yamcs.yarch.TableWriter

close, getTableDefinition

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.yamcs.yarch.StreamSubscriber

onTuple, streamClosed

Constructor Detail

AbstractTableWriter

public AbstractTableWriter(YarchDatabase ydb,
                           TableDefinition tableDefinition,
                           TableWriter.InsertMode mode)
                    throws FileNotFoundException

Throws:

FileNotFoundException

Method Detail

addHistogram

protected void addHistogram(YRDB db,
                            Tuple t)
                     throws org.rocksdb.RocksDBException

Throws:

org.rocksdb.RocksDBException

getHistogramColumnFamilyName

public static String getHistogramColumnFamilyName(String tableColumnName)

getDbPartition

public abstract RdbPartition getDbPartition(Tuple tuple)
                                     throws IOException

Throws:

IOException