Package org.yamcs.yarch

Class SelectStream

java.lang.Object

org.yamcs.yarch.Stream

org.yamcs.yarch.SelectStream

All Implemented Interfaces:

StreamSubscriber

public class SelectStream
extends Stream
implements StreamSubscriber

See Also:

• SelectExpression

Nested Class Summary

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

Stream.ExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
static final CompiledExpression	STAR

Fields inherited from class org.yamcs.yarch.Stream

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

Constructor Summary

Constructors

Constructor	Description
SelectStream(YarchDatabaseInstance ydb, Stream input, CompiledExpression cWhereClause, List<CompiledExpression> caggInputList, WindowProcessor wp, List<CompiledExpression> cselectList, TupleDefinition outputDef, TupleDefinition minOutputDef)

Method Summary

Modifier and Type	Method	Description
protected void	doClose()
void	doStart()	Start emitting tuples.
void	onTuple(Stream stream, Tuple t)
void	streamClosed(Stream stream)

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

Methods inherited from interface org.yamcs.yarch.StreamSubscriber

getDescription

Field Details

STAR

public static final CompiledExpression 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 filtering

wp - if null, then no windowProcessing (aggInputList is also null in this case)

cselectList -

outputDef - //output definition containing the expanded stars

minOutputDef - //output definition where stars are not included

Method Details

onTuple

public void onTuple(Stream stream,
 Tuple t)

Specified by:

onTuple in interface StreamSubscriber

streamClosed

public void streamClosed(Stream stream)

Specified by:

streamClosed in interface StreamSubscriber

doStart

public void doStart()

Description copied from class: Stream

Start emitting tuples.

Specified by:

doStart in class Stream

doClose

protected void doClose()

Specified by:

doClose in class Stream