org.yamcs.yarch

Class MergeStream

java.lang.Object

org.yamcs.yarch.AbstractStream

org.yamcs.yarch.MergeStream

All Implemented Interfaces:

Runnable, Stream, StreamSubscriber

public class MergeStream
extends AbstractStream
implements StreamSubscriber, Runnable

Field Summary

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

Method Summary

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

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

Constructor Detail

MergeStream

public MergeStream(YarchDatabase ydb,
                   AbstractStream[] 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

start

public void start()

Description copied from interface: Stream

Start emitting tuples.

Specified by:

start in interface Stream

Specified by:

start in class AbstractStream

run

public void run()

Specified by:

run in interface Runnable

doClose

protected void doClose()

Specified by:

doClose in class AbstractStream