org.yamcs.yarch.oldrocksdb

Class CfTableWriter

java.lang.Object

org.yamcs.yarch.TableWriter

org.yamcs.yarch.oldrocksdb.AbstractTableWriter

org.yamcs.yarch.oldrocksdb.CfTableWriter

All Implemented Interfaces:

StreamSubscriber

public class CfTableWriter
extends AbstractTableWriter

table writer that stores each partition by value in a different column family. It is also used when the table is not partitioned by value

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
CfTableWriter(YarchDatabaseInstance 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.oldrocksdb.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

CfTableWriter

public CfTableWriter(YarchDatabaseInstance 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

streamClosed

public void streamClosed(Stream stream)

close

public void close()

Description copied from class: TableWriter

close histogram db and any open resources

Specified by:

close in class TableWriter