org.yamcs.yarch.rocksdb

Class RdbTableWriter

java.lang.Object

org.yamcs.yarch.TableWriter

org.yamcs.yarch.rocksdb.RdbTableWriter

All Implemented Interfaces:

StreamSubscriber

public class RdbTableWriter
extends TableWriter

table writer that prepends the partition binary value in front of the key

Author:

nm

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
RdbTableWriter(Tablespace tablespace, YarchDatabaseInstance ydb, TableDefinition tableDefinition, TableWriter.InsertMode mode, RdbPartitionManager pm)

Method Summary

Modifier and Type	Method and Description
protected void	addHistogram(YRDB db, Tuple t)
void	close() close histogram db and any open resources
RdbPartition	getDbPartition(Tuple t) get the filename where the tuple would fit (can be a partition)
void	onTuple(Stream stream, Tuple t)
void	streamClosed(Stream stream)

Methods inherited from class org.yamcs.yarch.TableWriter

getTableDefinition

Methods inherited from class java.lang.Object

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

Constructor Detail

RdbTableWriter

public RdbTableWriter(Tablespace tablespace,
                      YarchDatabaseInstance ydb,
                      TableDefinition tableDefinition,
                      TableWriter.InsertMode mode,
                      RdbPartitionManager pm)

Method Detail

onTuple

public void onTuple(Stream stream,
                    Tuple t)

getDbPartition

public RdbPartition getDbPartition(Tuple t)
                            throws IOException

get the filename where the tuple would fit (can be a partition)

Parameters:

t -

Returns:

the partition where the tuple fits

Throws:

IOException - if there was an error while creating the directories where the file should be located

close

public void close()

Description copied from class: TableWriter

close histogram db and any open resources

Specified by:

close in class TableWriter

streamClosed

public void streamClosed(Stream stream)

addHistogram

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

Throws:

IOException

org.rocksdb.RocksDBException