org.yamcs.yarch

Class SelectStream

java.lang.Object

org.yamcs.yarch.AbstractStream

org.yamcs.yarch.SelectStream

All Implemented Interfaces:

Stream, StreamSubscriber

public class SelectStream
extends AbstractStream
implements StreamSubscriber

See Also:

SelectExpression

Field Summary

Fields

Modifier and Type	Field and Description
static CompiledExpression	STAR

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
SelectStream(YarchDatabase ydb, AbstractStream input, CompiledExpression cWhereClause, List<CompiledExpression> caggInputList, WindowProcessor wp, List<CompiledExpression> cselectList, TupleDefinition outputDef, TupleDefinition minOutputDef)

Method Summary

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

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

Field Detail

STAR

public static final CompiledExpression STAR

Constructor Detail

SelectStream

public SelectStream(YarchDatabase ydb,
                    AbstractStream 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 Detail

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

start

public void start()

Description copied from interface: Stream

Start emitting tuples.

Specified by:

start in interface Stream

Specified by:

start in class AbstractStream

doClose

protected void doClose()

Specified by:

doClose in class AbstractStream