Uses of Class
org.yamcs.yarch.AbstractStream

Packages that use AbstractStream

Package	Description
org.yamcs.yarch
org.yamcs.yarch.rocksdb
org.yamcs.yarch.streamsql

Uses of AbstractStream in org.yamcs.yarch

Subclasses of AbstractStream in org.yamcs.yarch

Modifier and Type	Class and Description
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 that return AbstractStream

Modifier and Type	Method and Description
AbstractStream	YarchDatabase.getStream(String name)
AbstractStream	StorageEngine.newTableReaderStream(TableDefinition tbl, boolean ascending, boolean follow) Creates a new table reader

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

Modifier and Type	Method and Description
Collection<AbstractStream>	YarchDatabase.getStreams()

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

Modifier and Type	Method and Description
void	YarchDatabase.addStream(AbstractStream stream) Adds a stream to the dictionary making it "official"

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

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

Uses of AbstractStream in org.yamcs.yarch.rocksdb

Subclasses of AbstractStream in org.yamcs.yarch.rocksdb

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 that return AbstractStream

Modifier and Type	Method and Description
AbstractStream	RdbStorageEngine.newTableReaderStream(TableDefinition tbl, boolean ascending, boolean follow)

Uses of AbstractStream in org.yamcs.yarch.streamsql

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

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