Uses of Class
org.yamcs.yarch.streamsql.StreamSqlException

Packages that use StreamSqlException

Package	Description
org.yamcs
org.yamcs.archive
org.yamcs.tctm
org.yamcs.yarch
org.yamcs.yarch.streamsql

Uses of StreamSqlException in org.yamcs

Methods in org.yamcs that throw StreamSqlException

Modifier and Type	Method and Description
void	StreamInitializer.createStreams()

Constructors in org.yamcs that throw StreamSqlException

Constructor and Description
ProcessorCreatorService(String yamcsInstance, Map<String,String> config)
YProcessorCreatorService(String yamcsInstance, Map<String,String> config) Deprecated.

Uses of StreamSqlException in org.yamcs.archive

Constructors in org.yamcs.archive that throw StreamSqlException

Constructor and Description
AlarmRecorder(String yamcsInstance)
EventRecorder(String instance)
XtceTmRecorder(String yamcsInstance)
XtceTmRecorder(String yamcsInstance, Map<String,Object> config) old constructor for compatibility with older configuration files

Uses of StreamSqlException in org.yamcs.tctm

Constructors in org.yamcs.tctm that throw StreamSqlException

Constructor and Description
DataLinkInitialiser(String yamcsInstance)
TcDataLinkInitialiser(String yamcsInstance)
TmProviderAdapter(String yamcsInstance) Deprecated.

Uses of StreamSqlException in org.yamcs.yarch

Methods in org.yamcs.yarch that throw StreamSqlException

Modifier and Type	Method and Description
boolean	AbstractTableReaderStream.addInFilter(ColumnExpression cexpr, Set<Object> values) currently adds only filters on value based partitions
boolean	DbReaderStream.addInFilter(ColumnExpression cexpr, Set<Object> values)
boolean	HistogramReaderStream.addRelOpFilter(ColumnExpression cexpr, RelOp relOp, Object value)
boolean	AbstractTableReaderStream.addRelOpFilter(ColumnExpression cexpr, RelOp relOp, Object value)
boolean	DbReaderStream.addRelOpFilter(ColumnExpression cexpr, RelOp relOp, Object value)
StreamSqlResult	YarchDatabaseInstance.execute(String query, Object... args)
void	TableDefinition.setHistogramColumns(List<String> histoColumns)
void	TableDefinition.setPartitioningSpec(PartitioningSpec pspec) time based partitions can be on the first column of the key (which has to be of type timestamp) value based partitions can be on any other mandatory column
void	TableDefinition.validate() Checks that the table definition is valid: - primary key not string, except for the last in the list (otherwise the binary sorting does not work properly)

Constructors in org.yamcs.yarch that throw StreamSqlException

Constructor and Description
MergeStream(YarchDatabaseInstance ydb, AbstractStream[] streams, String mergeColumn, boolean ascending)
TableDefinition(String name, TupleDefinition tdef, List<String> primaryKey) Used when creating an "empty"(i.e.

Uses of StreamSqlException in org.yamcs.yarch.streamsql

Subclasses of StreamSqlException in org.yamcs.yarch.streamsql

Modifier and Type	Class and Description
class	ColumnNotFoundException
class	GenericStreamSqlException
class	NotSupportedException
class	ResourceNotFoundException

Methods in org.yamcs.yarch.streamsql that throw StreamSqlException

Modifier and Type	Method and Description
Expression	InExpression.addFilter(DbReaderStream tableStream)
Expression	AndExpression.addFilter(DbReaderStream tableStream)
Expression	RelationalExpression.addFilter(DbReaderStream tableStream)
Expression	Expression.addFilter(DbReaderStream tableStream) add a filter to the table if applicable and returns an expression where the condition is removed.
Expression	OrExpression.addFilter(DbReaderStream tableStream)
AddOp	StreamSqlParser.AddOp()
protected void	SumExpression.aggregateFillCode_newData(StringBuilder code)
protected abstract void	CompilableAggregateExpression.aggregateFillCode_newData(StringBuilder code)
Expression	StreamSqlParser.AndExpression()
void	StreamSqlParser.Argument()
void	StreamSqlParser.Arguments()
void	StreamSqlParser.BetweenClause()
void	SpeedLimitStreamExpression.bind(ExecutionContext c)
void	SelectExpression.bind(ExecutionContext c)
void	Expression.bind(TupleDefinition inputDef2)
void	WindowSpecification.bind(TupleDefinition inputDef)
void	AggregateExpression.bind(TupleDefinition def)
void	AggregateExpression.bindAggregate(TupleDefinition def) When this is called, all the children are already bound.
CloseStreamStatement	StreamSqlParser.CloseStreamStatement()
void	StreamSqlParser.ColumnValue()
void	StreamSqlParser.ColumnValues()
CompiledExpression	Expression.compile()
CompiledExpression	ColumnExpression.compile()
CompiledExpression	AggregateExpression.compile()
CreateInputStreamStatement	StreamSqlParser.CreateInputStreamStatement()
CreateOutputStreamStatement	StreamSqlParser.CreateOutputStreamStatement()
CreateStreamStatement	StreamSqlParser.CreateStreamStatement()
CreateTableStatement	StreamSqlParser.CreateTableStatement()
DeleteStatement	StreamSqlParser.DeleteStatement()
protected void	InExpression.doBind()
void	AndExpression.doBind()
void	NotExpression.doBind()
void	RelationalExpression.doBind()
void	ExponentExpression.doBind()
protected abstract void	Expression.doBind()
void	ValueExpression.doBind()
void	AdditiveExpression.doBind()
void	ColumnExpression.doBind()
void	MultiplicativeExpression.doBind()
protected void	SumExpression.doBind()
void	OrExpression.doBind()
protected void	FirstValExpression.doBind()
void	NegativeExpression.doBind()
protected void	LikeExpression.doBind()
protected void	AggregateListExpression.doBind()
DropTableStatement	StreamSqlParser.DropTableStatement()
StreamSqlResult	CreateOutputStreamStatement.execute(ExecutionContext c)
StreamSqlResult	ShowStreamsStatement.execute(ExecutionContext c)
StreamSqlResult	ShowTablesStatement.execute(ExecutionContext c)
StreamSqlResult	CloseStreamStatement.execute(ExecutionContext c)
StreamSqlResult	CreateStreamStatement.execute(ExecutionContext c)
abstract StreamSqlResult	StreamSqlStatement.execute(ExecutionContext c)
StreamSqlResult	ShowStreamStatement.execute(ExecutionContext c)
AbstractStream	SpeedLimitStreamExpression.execute(ExecutionContext c)
AbstractStream	SelectExpression.execute(ExecutionContext c)
StreamSqlResult	DeleteStatement.execute(ExecutionContext c)
StreamSqlResult	InsertStatement.execute(ExecutionContext c)
StreamSqlResult	CreateInputStreamStatement.execute(ExecutionContext c)
StreamSqlResult	DropTableStatement.execute(ExecutionContext c)
StreamSqlResult	CreateTableStatement.execute(ExecutionContext c)
StreamSqlResult	MergeStatement.execute(ExecutionContext c)
Expression	StreamSqlParser.ExponentExpression()
Expression	StreamSqlParser.Expression()
List<Expression>	StreamSqlParser.ExpressionList()
protected void	InExpression.fillCode_Constructor(StringBuilder code)
protected void	Expression.fillCode_Constructor(StringBuilder code)
protected void	InExpression.fillCode_getValueBody(StringBuilder code)
protected void	Expression.fillCode_getValueBody(StringBuilder code)
void	InExpression.fillCode_getValueReturn(StringBuilder code)
void	AndExpression.fillCode_getValueReturn(StringBuilder code)
void	NotExpression.fillCode_getValueReturn(StringBuilder code)
void	RelationalExpression.fillCode_getValueReturn(StringBuilder code)
void	ExponentExpression.fillCode_getValueReturn(StringBuilder code)
protected abstract void	Expression.fillCode_getValueReturn(StringBuilder code)
void	ValueExpression.fillCode_getValueReturn(StringBuilder code)
void	AdditiveExpression.fillCode_getValueReturn(StringBuilder code)
void	ColumnExpression.fillCode_getValueReturn(StringBuilder code)
void	MultiplicativeExpression.fillCode_getValueReturn(StringBuilder code)
void	OrExpression.fillCode_getValueReturn(StringBuilder code)
void	NegativeExpression.fillCode_getValueReturn(StringBuilder code)
protected void	LikeExpression.fillCode_getValueReturn(StringBuilder code)
void	AggregateExpression.fillCode_getValueReturn(StringBuilder code)
List<Expression>	StreamSqlParser.FunctionArgumentList()
Expression	StreamSqlParser.FunctionCall()
CompiledAggregateExpression	FirstValExpression.getCompiledAggregate()
abstract CompiledAggregateExpression	AggregateExpression.getCompiledAggregate()
CompiledAggregateExpression	CompilableAggregateExpression.getCompiledAggregate()
CompiledAggregateExpression	AggregateListExpression.getCompiledAggregate()
List<Expression>	StreamSqlParser.InClause()
InsertStatement	StreamSqlParser.InsertAppendStatement()
InsertStatement	StreamSqlParser.InsertStatement()
void	StreamSqlParser.IntoClause()
void	StreamSqlParser.IsNullClause()
LikeClause	StreamSqlParser.LikeClause()
org.yamcs.yarch.streamsql.MergeExpression	StreamSqlParser.MergeExpression()
Expression	StreamSqlParser.MultiplicativeExpression()
MultOp	StreamSqlParser.MultOp()
BigDecimal	StreamSqlParser.NumericConstant()
String	StreamSqlParser.ObjectName()
StreamSqlStatement	StreamSqlParser.OneStatement()
boolean	StreamSqlParser.OrderClause()
PartitioningSpec	StreamSqlParser.PartitioningSpec()
TableDefinition.PartitionStorage	StreamSqlParser.PartitionStorage()
Expression	StreamSqlParser.PrimaryExpression()
Expression	StreamSqlParser.RelationalExpression()
RelOp	StreamSqlParser.RelOp()
SelectExpression	StreamSqlParser.Select()
SelectItem	StreamSqlParser.SelectItem()
List<SelectItem>	StreamSqlParser.SelectList()
SelectExpression	StreamSqlParser.SelectStatement()
ShowStreamsStatement	StreamSqlParser.ShowStreamsStatement()
ShowStreamStatement	StreamSqlParser.ShowStreamStatement()
ShowTablesStatement	StreamSqlParser.ShowTablesStatement()
Expression	StreamSqlParser.SimpleExpression()
SpeedLimitStreamExpression	StreamSqlParser.SpeedLimitStreamExpression()
SpeedSpec	StreamSqlParser.SpeedSpec()
org.yamcs.yarch.streamsql.StreamExpression	StreamSqlParser.StreamExpression()
StreamSqlStatement	StreamSqlParser.StreamSqlStatement()
void	StreamSqlParser.TableOption(CreateTableStatement cts)
TupleDefinition	StreamSqlParser.TupleDefinition()
TupleSourceExpression	StreamSqlParser.TupleSourceExpression()
Expression	StreamSqlParser.UnaryExpression()
Expression	StreamSqlParser.UnaryLogicalExpression()
InsertStatement	StreamSqlParser.UpsertAppendStatement()
InsertStatement	StreamSqlParser.UpsertStatement()
WindowSpecification	StreamSqlParser.WindowSpecification()