Uses of Interface
org.yamcs.yarch.Stream

Packages that use Stream

Package	Description
org.yamcs.alarms
org.yamcs.archive
org.yamcs.artemis
org.yamcs.cmdhistory
org.yamcs.parameter
org.yamcs.parameterarchive
org.yamcs.tctm
org.yamcs.utils
org.yamcs.web.rest
org.yamcs.web.rest.archive
org.yamcs.yarch
org.yamcs.yarch.management
org.yamcs.yarch.rocksdb

Uses of Stream in org.yamcs.alarms

Constructors in org.yamcs.alarms with parameters of type Stream

Constructor and Description
AlarmStreamer(Stream s)

Uses of Stream in org.yamcs.archive

Methods in org.yamcs.archive with parameters of type Stream

Modifier and Type	Method and Description
void	CccsdsTmIndex.onTuple(Stream stream, Tuple tuple)
void	YarchReplay.onTuple(Stream s, Tuple t)
void	CccsdsTmIndex.streamClosed(Stream stream)
void	YarchReplay.streamClosed(Stream stream)

Uses of Stream in org.yamcs.artemis

Methods in org.yamcs.artemis with parameters of type Stream

Modifier and Type	Method and Description
void	StreamAdapter.onTuple(Stream s, Tuple tuple) Deprecated.
void	StreamAdapter.streamClosed(Stream istream) Deprecated.

Constructors in org.yamcs.artemis with parameters of type Stream

Constructor and Description
StreamAdapter(Stream stream, org.apache.activemq.artemis.api.core.SimpleString hornetAddress, TupleTranslator translator) Deprecated.

Uses of Stream in org.yamcs.cmdhistory

Methods in org.yamcs.cmdhistory that return Stream

Modifier and Type	Method and Description
Stream	YarchCommandHistoryAdapter.getStream()

Methods in org.yamcs.cmdhistory with parameters of type Stream

Modifier and Type	Method and Description
void	StreamCommandHistoryProvider.onTuple(Stream s, Tuple tuple)
void	StreamCommandHistoryProvider.streamClosed(Stream stream)

Uses of Stream in org.yamcs.parameter

Methods in org.yamcs.parameter with parameters of type Stream

Modifier and Type	Method and Description
void	SystemParametersProvider.onTuple(Stream s, Tuple tuple)
void	SystemParametersProvider.streamClosed(Stream s)

Uses of Stream in org.yamcs.parameterarchive

Methods in org.yamcs.parameterarchive with parameters of type Stream

Modifier and Type	Method and Description
void	BackFiller.onTuple(Stream stream, Tuple tuple)
void	BackFiller.streamClosed(Stream stream)

Uses of Stream in org.yamcs.tctm

Methods in org.yamcs.tctm with parameters of type Stream

Modifier and Type	Method and Description
void	StreamParameterProvider.onTuple(Stream s, Tuple tuple) Make sure all parameters are defined in the XtceDB, otherwise the PRM will choke
void	StreamParameterProvider.streamClosed(Stream s)

Uses of Stream in org.yamcs.utils

Methods in org.yamcs.utils with parameters of type Stream

Modifier and Type	Method and Description
static org.slf4j.Logger	LoggingUtils.getLogger(Class<?> clazz, String instance, Stream stream)

Uses of Stream in org.yamcs.web.rest

Methods in org.yamcs.web.rest that return Stream

Modifier and Type	Method and Description
protected static Stream	RestHandler.verifyStream(RestRequest req, YarchDatabase ydb, String streamName)

Methods in org.yamcs.web.rest with parameters of type Stream

Modifier and Type	Method and Description
void	RestStreamSubscriber.onTuple(Stream stream, Tuple tuple)
void	StreamToChunkedTransferEncoder.processTuple(Stream stream, Tuple tuple)
abstract void	RestStreamSubscriber.processTuple(Stream stream, Tuple tuple)
void	StreamToChunkedTransferEncoder.streamClosed(Stream stream)

Uses of Stream in org.yamcs.web.rest.archive

Methods in org.yamcs.web.rest.archive with parameters of type Stream

Modifier and Type	Method and Description
static Archive.StreamData	ArchiveHelper.toStreamData(Stream stream, Tuple tuple)

Uses of Stream in org.yamcs.yarch

Classes in org.yamcs.yarch that implement Stream

Modifier and Type	Class and Description
class	AbstractStream
class	AbstractTableReaderStream Implements skeleton for table streamer that uses PartitionManager to handle partitioning.
class	HistogramReaderStream Sends histogram data to a stream.
class	InputStream
class	InternalStream
class	MergeStream
class	OutputStream
class	SelectStream
class	SpeedLimitStream

Methods in org.yamcs.yarch with parameters of type Stream

Modifier and Type	Method and Description
void	OutputStream.onTuple(Stream s, Tuple t)
void	SelectStream.onTuple(Stream stream, Tuple t)
void	MergeStream.onTuple(Stream s, Tuple tuple)
void	SpeedLimitStream.onTuple(Stream s, Tuple t)
void	StreamSubscriber.onTuple(Stream stream, Tuple tuple)
void	OutputStream.setSubscribedStream(Stream s)
void	SpeedLimitStream.setSubscribedStream(Stream s)
void	OutputStream.streamClosed(Stream stream) Called when the subcribed stream is closed we close this stream also.
void	SelectStream.streamClosed(Stream stream)
void	MergeStream.streamClosed(Stream s)
void	SpeedLimitStream.streamClosed(Stream stream) Called when the subcribed stream is closed we close this stream also.
void	StreamSubscriber.streamClosed(Stream stream)

Uses of Stream in org.yamcs.yarch.management

Methods in org.yamcs.yarch.management with parameters of type Stream

Modifier and Type	Method and Description
void	JMXService.registerStream(String instance, Stream stream)

Uses of Stream in org.yamcs.yarch.rocksdb

Classes in org.yamcs.yarch.rocksdb that implement Stream

Modifier and Type	Class and Description
class	CfTableReaderStream reader for tables where each partition is a different column family Also works for the case when there is no partitioning by value
class	InkeyTableReaderStream reader for tables with PartitionStorage.IN_KEY (the partition is prepended in front of the key)

Methods in org.yamcs.yarch.rocksdb with parameters of type Stream

Modifier and Type	Method and Description
void	CfTableWriter.onTuple(Stream stream, Tuple t)
void	InKeyTableWriter.onTuple(Stream stream, Tuple t)
void	CfTableWriter.streamClosed(Stream stream)
void	InKeyTableWriter.streamClosed(Stream stream)