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.commanding
org.yamcs.http.api
org.yamcs.management
org.yamcs.parameterarchive
org.yamcs.tctm
org.yamcs.tctm.cfs
org.yamcs.tse
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, FileSaveHandler fileSaveHandler, EventProducer eventProducer, TransferMonitor monitor, Map<ConditionCode,org.yamcs.cfdp.OngoingCfdpTransfer.FaultHandlingAction> faultHandlerActions)
	CfdpOutgoingTransfer(String yamcsInstance, long initiatorEntityId, long id, long creationTime, ScheduledThreadPoolExecutor executor, PutRequest request, Stream cfdpOut, YConfiguration config, Bucket bucket, Integer customPduSize, Integer customPduDelay, 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.commanding

Methods in org.yamcs.commanding that return Stream

Modifier and Type	Method	Description
Stream	PreparedCommand.getTcStream()

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

Modifier and Type	Method	Description
void	PreparedCommand.setTcStream(Stream tcStream)	Specify the target TC 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 MDB, 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.tse

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

Modifier	Constructor	Description
	TseDataLinkInboundHandler(CommandHistoryPublisher cmdhistPublisher, Mdb mdb, TimeService timeService, 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	Stream created by the "create stream statement"
class	MergeStream
class	OutputStream
class	SelectStream
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	InternalStream.onTuple(Stream stream, Tuple tuple)
void	MergeStream.onTuple(Stream s, Tuple tuple)
void	OutputStream.onTuple(Stream s, Tuple t)
void	SelectStream.onTuple(Stream stream, Tuple t)
void	StreamSubscriber.onTuple(Stream stream, Tuple tuple)
void	InternalStream.setInner(Stream inner)
void	OutputStream.setSubscribedStream(Stream s)
void	InternalStream.streamClosed(Stream stream)
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)
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)

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)