Uses of Class
org.yamcs.yarch.Stream

Packages that use Stream

Package	Description
org.yamcs.alarms
org.yamcs.archive
org.yamcs.cfdp
org.yamcs.cmdhistory
org.yamcs.http.api
org.yamcs.http.websocket
org.yamcs.management
org.yamcs.parameterarchive
org.yamcs.replication
org.yamcs.tctm
org.yamcs.tctm.cfs
org.yamcs.yarch
org.yamcs.yarch.management
org.yamcs.yarch.rocksdb
org.yamcs.yarch.streamsql

Uses of Stream in org.yamcs.alarms

Fields in org.yamcs.alarms declared as Stream

Modifier and Type	Field	Description
protected Stream	AlarmStreamer.stream

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

Constructor	Description
AlarmStreamer(Stream s, DataType dataType, TupleDefinition tdefTemplate)
EventAlarmStreamer(Stream s)
ParameterAlarmStreamer(Stream s)

Uses of Stream in org.yamcs.archive

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

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

Uses of Stream in org.yamcs.cfdp

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

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

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

Constructor	Description
CfdpIncomingTransfer(String yamcsInstance, ScheduledThreadPoolExecutor executor, YConfiguration config, CfdpTransactionId id, Stream cfdpOut, Bucket target, EventProducer eventProducer, TransferMonitor monitor)
CfdpIncomingTransfer(String yamcsInstance, ScheduledThreadPoolExecutor executor, YConfiguration config, MetadataPacket packet, Stream cfdpOut, Bucket target, EventProducer eventProducer, TransferMonitor monitor)
CfdpOutgoingTransfer(String yamcsInstance, ScheduledThreadPoolExecutor executor, PutRequest request, Stream cfdpOut, YConfiguration config, EventProducer eventProducer, TransferMonitor monitor)
CfdpTransfer(String yamcsInstance, ScheduledThreadPoolExecutor executor, YConfiguration config, long initiatorEntity, Stream cfdpOut, EventProducer eventProducer, TransferMonitor monitor)
CfdpTransfer(String yamcsInstance, ScheduledThreadPoolExecutor executor, YConfiguration config, CfdpTransactionId cfdpTransactionId, Stream cfdpOut, EventProducer eventProducer, TransferMonitor monitor)

Uses of Stream in org.yamcs.cmdhistory

Methods in org.yamcs.cmdhistory that return Stream

Modifier and Type	Method	Description
Stream	StreamCommandHistoryPublisher.getStream()

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

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

Uses of Stream in org.yamcs.http.api

Methods in org.yamcs.http.api that return Stream

Modifier and Type	Method	Description
static Stream	StreamFactory.insertStream(String instance, TableDefinition table)
static Stream	TableApi.verifyStream(Context ctx, YarchDatabaseInstance ydb, String streamName)

Uses of Stream in org.yamcs.http.websocket

Methods in org.yamcs.http.websocket with parameters of type Stream

Modifier and Type	Method	Description
void	StreamResource.onTuple(Stream stream, Tuple tuple)
void	StreamResource.streamClosed(Stream stream)
void	StreamsResource.streamRegistered(String instance, Stream stream)

Uses of Stream in org.yamcs.management

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

Modifier and Type	Method	Description
void	ManagementService.registerStream(String instance, Stream stream)
default void	TableStreamListener.streamRegistered(String instance, Stream stream)

Uses of Stream in org.yamcs.parameterarchive

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

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

Uses of Stream in org.yamcs.replication

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

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

Uses of Stream in org.yamcs.tctm

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

Modifier and Type	Method	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)

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

Constructor	Description
StreamParameterSender(String yamcsInstance, Stream stream)
StreamPbParameterSender(String yamcsInstance, Stream stream)

Uses of Stream in org.yamcs.tctm.cfs

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

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

Uses of Stream in org.yamcs.yarch

Subclasses of Stream in org.yamcs.yarch

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

Methods in org.yamcs.yarch that return Stream

Modifier and Type	Method	Description
Stream	YarchDatabaseInstance.getStream(String name)
Stream	StorageEngine.newTableReaderStream(YarchDatabaseInstance ydb, TableDefinition tblDef, boolean ascending, boolean follow)	Creates a new table reader.

Methods in org.yamcs.yarch that return types with arguments of type Stream

Modifier and Type	Method	Description
Collection<Stream>	YarchDatabaseInstance.getStreams()

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

Modifier and Type	Method	Description
void	YarchDatabaseInstance.addStream(Stream stream)	Adds a stream to the dictionary making it "official"
void	MergeStream.onTuple(Stream s, Tuple tuple)
void	OutputStream.onTuple(Stream s, Tuple t)
void	SelectStream.onTuple(Stream stream, Tuple t)
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	MergeStream.streamClosed(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	SpeedLimitStream.streamClosed(Stream stream)	Called when the subcribed stream is closed we close this stream also.
default void	StreamSubscriber.streamClosed(Stream stream)

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

Constructor	Description
MergeStream(YarchDatabaseInstance ydb, Stream[] streams, String mergeColumn, boolean ascending)
SelectStream(YarchDatabaseInstance ydb, Stream input, CompiledExpression cWhereClause, List<CompiledExpression> caggInputList, WindowProcessor wp, List<CompiledExpression> cselectList, TupleDefinition outputDef, TupleDefinition minOutputDef)

Uses of Stream in org.yamcs.yarch.management

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

Constructor	Description
StreamControlImpl(Stream stream)

Uses of Stream in org.yamcs.yarch.rocksdb

Subclasses of Stream in org.yamcs.yarch.rocksdb

Modifier and Type	Class	Description
class	RdbTableReaderStream	reader for tables with PartitionStorage.IN_KEY (the partition is prepended in front of the key)

Methods in org.yamcs.yarch.rocksdb that return Stream

Modifier and Type	Method	Description
Stream	RdbStorageEngine.newTableReaderStream(YarchDatabaseInstance ydb, TableDefinition tbl, boolean ascending, boolean follow)
Stream	Tablespace.newTableReaderStream(YarchDatabaseInstance ydb, TableDefinition tblDef, boolean ascending, boolean follow)

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

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

Uses of Stream in org.yamcs.yarch.streamsql

Subclasses of Stream in org.yamcs.yarch.streamsql

Modifier and Type	Class	Description
class	LimitedStream

Methods in org.yamcs.yarch.streamsql that return Stream

Modifier and Type	Method	Description
Stream	SelectExpression.execute(ExecutionContext c)
Stream	SpeedLimitStreamExpression.execute(ExecutionContext c)

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

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

Constructors in org.yamcs.yarch.streamsql with parameters of type Stream

Constructor	Description
LimitedStream(YarchDatabaseInstance ydb, Stream input, BigDecimal offset, BigDecimal limit, TupleDefinition definition)