org.yamcs.yarch

Class HistogramReaderStream

java.lang.Object

org.yamcs.yarch.AbstractStream

org.yamcs.yarch.HistogramReaderStream

All Implemented Interfaces:

Runnable, DbReaderStream, Stream

public class HistogramReaderStream
extends AbstractStream
implements Runnable, DbReaderStream

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

Author:

nm

Field Summary

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

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

Method Summary

Modifier and Type	Method and Description
boolean	addInFilter(ColumnExpression cexpr, 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	run()
void	setMergeTime(long mergeTime)
void	start() Start emitting tuples.

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

Constructor Detail

HistogramReaderStream

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

Throws:

YarchException

Method Detail

start

public void start()

Description copied from interface: Stream

Start emitting tuples.

Specified by:

start in interface Stream

Specified by:

start in class AbstractStream

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,
                           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 AbstractStream