Package org.yamcs.yarch
Class HistogramReaderStream
java.lang.Object
org.yamcs.yarch.Stream
org.yamcs.yarch.HistogramReaderStream
- All Implemented Interfaces:
Runnable
Sends histogram data to a stream.
The definition of the emitted tuples is in
TupleSourceExpression.bind(org.yamcs.yarch.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
ConstructorDescriptionHistogramReaderStream
(YarchDatabaseInstance ydb, TableDefinition tblDef, String histoColumnName, TupleDefinition tupleDef) -
Method Summary
Modifier and TypeMethodDescriptionvoid
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
-
Constructor Details
-
HistogramReaderStream
public HistogramReaderStream(YarchDatabaseInstance ydb, TableDefinition tblDef, String histoColumnName, TupleDefinition tupleDef) throws YarchException - Throws:
YarchException
-
-
Method Details
-
doStart
public void doStart()Description copied from class:Stream
Start emitting tuples. -
run
public void run() -
setTimeInterval
Retrieve only the histograms overlapping with this interval.- Parameters:
filter
-
-
setMergeTime
public void setMergeTime(long mergeTime) -
doClose
public void doClose()
-