Package org.yamcs.yarch

Class HistogramReaderStream

java.lang.Object

org.yamcs.yarch.Stream

org.yamcs.yarch.HistogramReaderStream

All Implemented Interfaces:

Runnable

public class HistogramReaderStream
extends Stream
implements Runnable

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
void	doClose()
void	doStart()	Start emitting tuples.
void	run()
void	setMergeTime(long mergeTime)
void	setTimeInterval(TimeInterval filter)	Retrieve only the histograms overlapping with this interval.

Methods inherited from class org.yamcs.yarch.Stream

addSubscriber, close, emitTuple, exceptionHandler, getColumnDefinition, getDataCount, getDefinition, getName, getState, getSubscriberCount, getSubscribers, isClosed, 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

setTimeInterval

public void setTimeInterval(TimeInterval filter)

Retrieve only the histograms overlapping with this interval.

Parameters:

filter -

setMergeTime

public void setMergeTime(long mergeTime)

doClose

public void doClose()

Specified by:

doClose in class Stream