Package 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

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

Method Summary

Modifier and Type	Method	Description
protected void	addHistogram(YRDB rdb, Tuple t)
protected void	doClose()
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

close, closeFuture, 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)

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

doClose

protected void doClose()

Specified by:

doClose in class TableWriter

streamClosed

public void streamClosed(Stream stream)

addHistogram

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

Throws:

IOException

org.rocksdb.RocksDBException