org.yamcs.yarch.rocksdb

Class CfTableReaderStream

java.lang.Object

org.yamcs.yarch.AbstractStream

org.yamcs.yarch.AbstractTableReaderStream

org.yamcs.yarch.rocksdb.CfTableReaderStream

All Implemented Interfaces:

Runnable, DbReaderStream, Stream

public class CfTableReaderStream
extends AbstractTableReaderStream
implements Runnable, DbReaderStream

reader for tables where each partition is a different column family Also works for the case when there is no partitioning by value

Author:

nm

Field Summary

Fields inherited from class org.yamcs.yarch.AbstractTableReaderStream

ascending, follow, quit

Fields inherited from class org.yamcs.yarch.AbstractStream

log, name, outputDefinition, state, subscribers, ydb

Fields inherited from interface org.yamcs.yarch.Stream

QUITTING, RUNNING, SETUP

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	CfTableReaderStream(YarchDatabaseInstance ydb, TableDefinition tblDef, RdbPartitionManager partitionManager, boolean ascending, boolean follow)

Method Summary

Modifier and Type	Method and Description
long	getNumRecordsRead()
protected boolean	runPartitions(List<Partition> partitions, IndexFilter range) reads a file, sending data only that conform with the start and end filters.
void	start() Start emitting tuples.

Methods inherited from class org.yamcs.yarch.AbstractTableReaderStream

addInFilter, addRelOpFilter, compare, dataToTuple, doClose, emitIfNotPastStart, emitIfNotPastStop, getTableDefinition, run

Methods inherited from class org.yamcs.yarch.AbstractStream

addSubscriber, close, emitTuple, getColumnDefinition, getDefinition, getName, getNumEmittedTuples, getState, getSubscriberCount, getSubscribers, removeSubscriber, setName, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Runnable

run

Methods inherited from interface org.yamcs.yarch.DbReaderStream

addInFilter, addRelOpFilter

Constructor Detail

CfTableReaderStream

protected CfTableReaderStream(YarchDatabaseInstance ydb,
                              TableDefinition tblDef,
                              RdbPartitionManager partitionManager,
                              boolean ascending,
                              boolean follow)

Method Detail

start

public void start()

Description copied from interface: Stream

Start emitting tuples.

Specified by:

start in interface Stream

Overrides:

start in class AbstractTableReaderStream

runPartitions

protected boolean runPartitions(List<Partition> partitions,
                                IndexFilter range)
                         throws IOException

reads a file, sending data only that conform with the start and end filters. returns true if the stop condition is met All the partitions are from the same time interval and thus from one single RocksDB database

Specified by:

runPartitions in class AbstractTableReaderStream

Throws:

IOException

getNumRecordsRead

public long getNumRecordsRead()