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.management
org.yamcs.parameterarchive
org.yamcs.tctm
org.yamcs.tctm.cfs
org.yamcs.yarch
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

Modifier	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

Modifier	Constructor	Description
	CfdpIncomingTransfer(String yamcsInstance, long id, long creationTime, ScheduledThreadPoolExecutor executor, YConfiguration config, CfdpHeader hdr, Stream cfdpOut, Bucket target, EventProducer eventProducer, TransferMonitor monitor, Map<ConditionCode,org.yamcs.cfdp.OngoingCfdpTransfer.FaultHandlingAction> faultHandlerActions)
	CfdpOutgoingTransfer(String yamcsInstance, long id, long creationTime, ScheduledThreadPoolExecutor executor, PutRequest request, Stream cfdpOut, YConfiguration config, EventProducer eventProducer, TransferMonitor monitor, Map<ConditionCode,org.yamcs.cfdp.OngoingCfdpTransfer.FaultHandlingAction> faultHandlerActions)	Create a new CFDP outgoing (uplink) transfer.
	OngoingCfdpTransfer(String yamcsInstance, long id, long creationTime, ScheduledThreadPoolExecutor executor, YConfiguration config, CfdpTransactionId cfdpTransactionId, long destinationId, Stream cfdpOut, EventProducer eventProducer, TransferMonitor monitor, Map<ConditionCode,org.yamcs.cfdp.OngoingCfdpTransfer.FaultHandlingAction> faultHandlerActions)

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	StreamFactory.loadStream(String instance, TableDefinition table)
static Stream	TableApi.verifyStream(Context ctx, YarchDatabaseInstance ydb, String streamName)

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.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

Modifier	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	HistogramReaderStream	Sends histogram data to a stream.
class	InternalStream	The simplest stream implementation, just passes data to the subscribers
class	MergeStream
class	OutputStream
class	SelectStream
class	SpeedLimitStream
class	TableReaderStream	Implements skeleton for table streamer that uses PartitionManager to handle partitioning.

Methods in org.yamcs.yarch that return Stream

Modifier and Type	Method	Description
Stream	YarchDatabaseInstance.getStream(String name)

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

Modifier	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.rocksdb

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	InsertValuesExpression.execute(ExecutionContext c)
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

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