org.yamcs.yarch.rocksdb

Class InKeyTableWriter

java.lang.Object

org.yamcs.yarch.TableWriter

org.yamcs.yarch.rocksdb.AbstractTableWriter

org.yamcs.yarch.rocksdb.InKeyTableWriter

All Implemented Interfaces:

StreamSubscriber

public class InKeyTableWriter
extends AbstractTableWriter

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
InKeyTableWriter(YarchDatabase ydb, TableDefinition tableDefinition, TableWriter.InsertMode mode, RdbPartitionManager pm)

Method Summary

Modifier and Type	Method and Description
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.rocksdb.AbstractTableWriter

addHistogram, getHistogramColumnFamilyName

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

InKeyTableWriter

public InKeyTableWriter(YarchDatabase ydb,
                        TableDefinition tableDefinition,
                        TableWriter.InsertMode mode,
                        RdbPartitionManager pm)
                 throws IOException

Throws:

IOException

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)

Specified by:

getDbPartition in class AbstractTableWriter

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)