Package org.yamcs.yarch

Class MergeStream

java.lang.Object

org.yamcs.yarch.Stream

org.yamcs.yarch.MergeStream

All Implemented Interfaces:

Runnable, StreamSubscriber

public class MergeStream
extends Stream
implements StreamSubscriber, Runnable

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
MergeStream(YarchDatabaseInstance ydb, Stream[] streams, String mergeColumn, boolean ascending)

Method Summary

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

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

MergeStream

public MergeStream(YarchDatabaseInstance ydb,
                   Stream[] streams,
                   String mergeColumn,
                   boolean ascending)
            throws StreamSqlException

Throws:

StreamSqlException

Method Detail

onTuple

public void onTuple(Stream s,
                    Tuple tuple)

Specified by:

onTuple in interface StreamSubscriber

streamClosed

public void streamClosed(Stream s)

Specified by:

streamClosed in interface StreamSubscriber

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

doClose

protected void doClose()

Specified by:

doClose in class Stream