Package org.yamcs.yarch
Class SelectStream
java.lang.Object
org.yamcs.yarch.Stream
org.yamcs.yarch.SelectStream
- All Implemented Interfaces:
StreamSubscriber
- See Also:
-
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
ConstructorDescriptionSelectStream
(YarchDatabaseInstance ydb, Stream input, CompiledExpression cWhereClause, List<CompiledExpression> caggInputList, WindowProcessor wp, List<CompiledExpression> cselectList, TupleDefinition outputDef, TupleDefinition minOutputDef) -
Method Summary
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
-
Field Details
-
STAR
-
-
Constructor Details
-
SelectStream
public SelectStream(YarchDatabaseInstance ydb, Stream input, CompiledExpression cWhereClause, List<CompiledExpression> caggInputList, WindowProcessor wp, List<CompiledExpression> cselectList, TupleDefinition outputDef, TupleDefinition minOutputDef) - Parameters:
ydb
-input
-cWhereClause
- if null, then no where filteringwp
- if null, then no windowProcessing (aggInputList is also null in this case)cselectList
-outputDef
- //output definition containing the expanded starsminOutputDef
- //output definition where stars are not included
-
-
Method Details
-
onTuple
- Specified by:
onTuple
in interfaceStreamSubscriber
-
streamClosed
- Specified by:
streamClosed
in interfaceStreamSubscriber
-
doStart
public void doStart()Description copied from class:Stream
Start emitting tuples. -
doClose
protected void doClose()
-