Package org.yamcs.yarch

Class HistogramReaderStream

java.lang.Object

org.yamcs.yarch.Stream

org.yamcs.yarch.HistogramReaderStream

All Implemented Interfaces:

Runnable, DbReaderStream

public class HistogramReaderStream
extends Stream
implements Runnable, DbReaderStream

Sends histogram data to a stream. The definition of the emitted tuples is in TupleSourceExpression.bind(org.yamcs.yarch.streamsql.ExecutionContext)

Nested Class Summary

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

Stream.ExceptionHandler

Field Summary

Fields inherited from class org.yamcs.yarch.Stream

log, name, outputDefinition, QUITTING, RUNNING, SETUP, state, subscribers, ydb

Constructor Summary

Constructors

Constructor	Description
HistogramReaderStream(YarchDatabaseInstance ydb, TableDefinition tblDef, String histoColumnName, TupleDefinition tupleDef)

Method Summary

Modifier and Type	Method	Description
boolean	addInFilter(ColumnExpression cexpr, boolean negation, Set<Object> values)	could filter on the histoColumn values, not done for the moment
boolean	addRelOpFilter(ColumnExpression cexpr, RelOp relOp, Object value)
void	doClose()
void	doStart()	Start emitting tuples.
void	run()
void	setMergeTime(long mergeTime)

Methods inherited from class org.yamcs.yarch.Stream

addSubscriber, close, emitTuple, exceptionHandler, getColumnDefinition, getDataCount, getDefinition, getName, getState, getSubscriberCount, getSubscribers, isRunning, quitting, removeSubscriber, setName, start, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

HistogramReaderStream

public HistogramReaderStream(YarchDatabaseInstance ydb,
                             TableDefinition tblDef,
                             String histoColumnName,
                             TupleDefinition tupleDef)
                      throws YarchException

Throws:

YarchException

Method Detail

doStart

public void doStart()

Description copied from class: Stream

Start emitting tuples.

Specified by:

doStart in class Stream

run

public void run()

Specified by:

run in interface Runnable

addRelOpFilter

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

Specified by:

addRelOpFilter in interface DbReaderStream

Throws:

StreamSqlException

addInFilter

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

could filter on the histoColumn values, not done for the moment

Specified by:

addInFilter in interface DbReaderStream

setMergeTime

public void setMergeTime(long mergeTime)

doClose

public void doClose()

Specified by:

doClose in class Stream