org.yamcs.yarch

Class AbstractTableReaderStream

java.lang.Object

org.yamcs.yarch.AbstractStream

org.yamcs.yarch.AbstractTableReaderStream

All Implemented Interfaces:

Runnable, DbReaderStream, Stream

Direct Known Subclasses:

CfTableReaderStream, InkeyTableReaderStream, RdbTableReaderStream

public abstract class AbstractTableReaderStream
extends AbstractStream
implements Runnable, DbReaderStream

Implements skeleton for table streamer that uses PartitionManager to handle partitioning.

Author:

nm

Nested Class Summary

Nested classes/interfaces inherited from interface org.yamcs.yarch.Stream

Stream.ExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	ascending
protected boolean	follow
protected PartitionManager	partitionManager
protected boolean	quit
protected TableDefinition	tableDefinition

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	AbstractTableReaderStream(YarchDatabaseInstance ydb, TableDefinition tblDef, PartitionManager partitionManager, boolean ascending, boolean follow)

Method Summary

Modifier and Type	Method and Description
boolean	addInFilter(ColumnExpression cexpr, Set<Object> values) currently adds only filters on value based partitions
boolean	addRelOpFilter(ColumnExpression cexpr, RelOp relOp, Object value)
protected int	compare(byte[] a1, byte[] a2)
protected Tuple	dataToTuple(byte[] k, byte[] v)
void	doClose()
protected boolean	emitIfNotPastStart(byte[] key, byte[] value, byte[] rangeStart, boolean strictStart)
protected boolean	emitIfNotPastStop(byte[] key, byte[] value, byte[] rangeEnd, boolean strictEnd)
TableDefinition	getTableDefinition()
void	run()
protected abstract boolean	runPartitions(List<Partition> partitions, IndexFilter range) Runs the partitions sending data only that conform with the start and end filters.

Methods inherited from class org.yamcs.yarch.AbstractStream

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

Methods inherited from class java.lang.Object

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

Field Detail

tableDefinition

protected TableDefinition tableDefinition

quit

protected volatile boolean quit

partitionManager

protected final PartitionManager partitionManager

ascending

protected final boolean ascending

follow

protected final boolean follow

Constructor Detail

AbstractTableReaderStream

protected AbstractTableReaderStream(YarchDatabaseInstance ydb,
                                    TableDefinition tblDef,
                                    PartitionManager partitionManager,
                                    boolean ascending,
                                    boolean follow)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

runPartitions

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

Runs the partitions 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

Throws:

IOException

emitIfNotPastStop

protected boolean emitIfNotPastStop(byte[] key,
                                    byte[] value,
                                    byte[] rangeEnd,
                                    boolean strictEnd)

emitIfNotPastStart

protected boolean emitIfNotPastStart(byte[] key,
                                     byte[] value,
                                     byte[] rangeStart,
                                     boolean strictStart)

addRelOpFilter

public boolean addRelOpFilter(ColumnExpression cexpr,
                              RelOp relOp,
                              Object value)
                       throws StreamSqlException

Specified by:

addRelOpFilter in interface DbReaderStream

Throws:

StreamSqlException

dataToTuple

protected Tuple dataToTuple(byte[] k,
                            byte[] v)

addInFilter

public boolean addInFilter(ColumnExpression cexpr,
                           Set<Object> values)
                    throws StreamSqlException

currently adds only filters on value based partitions

Specified by:

addInFilter in interface DbReaderStream

Throws:

StreamSqlException

doClose

public void doClose()

Specified by:

doClose in class AbstractStream

getTableDefinition

public TableDefinition getTableDefinition()

compare

protected int compare(byte[] a1,
                      byte[] a2)