org.yamcs.yarch

Class AbstractStream

java.lang.Object

org.yamcs.yarch.AbstractStream

All Implemented Interfaces:

Stream

Direct Known Subclasses:

AbstractTableReaderStream, HistogramReaderStream, InputStream, InternalStream, MergeStream, OutputStream, SelectStream, SpeedLimitStream

public abstract class AbstractStream
extends Object
implements Stream

Field Summary

Fields

Modifier and Type	Field and Description
protected org.slf4j.Logger	log
protected String	name
protected TupleDefinition	outputDefinition
protected int	state
protected Collection<StreamSubscriber>	subscribers
protected YarchDatabase	ydb

Fields inherited from interface org.yamcs.yarch.Stream

QUITTING, RUNNING, SETUP

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractStream(YarchDatabase ydb, String name, TupleDefinition definition)

Method Summary

Modifier and Type	Method and Description
void	addSubscriber(StreamSubscriber s)
void	close() Closes the stream by: send the streamClosed signal to all subscribed clients
protected abstract void	doClose()
void	emitTuple(Tuple t)
ColumnDefinition	getColumnDefinition(String colName)
TupleDefinition	getDefinition()
String	getName()
long	getNumEmittedTuples()
int	getState()
int	getSubscriberCount()
Collection<StreamSubscriber>	getSubscribers()
void	removeSubscriber(StreamSubscriber s)
void	setName(String streamName)
abstract void	start() Start emitting tuples.
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

name

protected String name

outputDefinition

protected TupleDefinition outputDefinition

subscribers

protected final Collection<StreamSubscriber> subscribers

state

protected volatile int state

log

protected org.slf4j.Logger log

ydb

protected YarchDatabase ydb

Constructor Detail

AbstractStream

protected AbstractStream(YarchDatabase ydb,
                         String name,
                         TupleDefinition definition)

Method Detail

start

public abstract void start()

Description copied from interface: Stream

Start emitting tuples.

Specified by:

start in interface Stream

getDefinition

public TupleDefinition getDefinition()

Specified by:

getDefinition in interface Stream

emitTuple

public void emitTuple(Tuple t)

Specified by:

emitTuple in interface Stream

getName

public String getName()

Specified by:

getName in interface Stream

setName

public void setName(String streamName)

Specified by:

setName in interface Stream

addSubscriber

public void addSubscriber(StreamSubscriber s)

Specified by:

addSubscriber in interface Stream

removeSubscriber

public void removeSubscriber(StreamSubscriber s)

Specified by:

removeSubscriber in interface Stream

getColumnDefinition

public ColumnDefinition getColumnDefinition(String colName)

Specified by:

getColumnDefinition in interface Stream

close

public final void close()

Description copied from interface: Stream

Closes the stream by: send the streamClosed signal to all subscribed clients

Specified by:

close in interface Stream

doClose

protected abstract void doClose()

toString

public String toString()

Overrides:

toString in class Object

getState

public int getState()

Specified by:

getState in interface Stream

getNumEmittedTuples

public long getNumEmittedTuples()

Specified by:

getNumEmittedTuples in interface Stream

getSubscriberCount

public int getSubscriberCount()

Specified by:

getSubscriberCount in interface Stream

getSubscribers

public Collection<StreamSubscriber> getSubscribers()

Specified by:

getSubscribers in interface Stream