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

Packages that use StreamSqlException

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

Uses of StreamSqlException in org.yamcs

Methods in org.yamcs that throw StreamSqlException

Modifier and Type	Method	Description
void	StreamInitializer.createStreams()

Uses of StreamSqlException in org.yamcs.yarch

Methods in org.yamcs.yarch that throw StreamSqlException

Modifier and Type	Method	Description
void	FilterableTarget.addInFilter(ColumnExpression cexpr, boolean negation, Set<Object> values)	same as FilterableTarget.addRelOpFilter(ColumnExpression, RelOp, Object) but adds a restrictions for a set of values resulted from a where x in (a,b,c) condition
void	FilterableTarget.addRelOpFilter(ColumnExpression cexpr, RelOp relOp, Object value)	Tries to add a restriction for the rows to be selected/updated/deleted.
StreamSqlStatement	YarchDatabaseInstance.createStatement(String query, Object... args)
StreamSqlResult	YarchDatabaseInstance.execute(String query, Object... args)	Executes a query and returns a result.
StreamSqlResult	YarchDatabaseInstance.execute(StreamSqlStatement stmt)
void	YarchDatabaseInstance.execute(StreamSqlStatement stmt, ResultListener resultListener)
void	YarchDatabaseInstance.execute(StreamSqlStatement stmt, ResultListener resultListener, long limit)
void	YarchDatabaseInstance.executeDiscardingResult(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.setSecondaryIndex(List<String> index)
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)
void	AbstractTableWalker.walk(TableVisitor visitor)
void	TableWalker.walk(TableVisitor visitor)
protected abstract boolean	AbstractTableWalker.walkInterval(PartitionManager.Interval interval, DbRange range, TableVisitor visitor)	Runs the data in a time interval (corresponding to a time partition) sending data only that conform with the start and end filters.

Constructors in org.yamcs.yarch that throw StreamSqlException

Constructor	Description
MergeStream(YarchDatabaseInstance ydb, Stream[] streams, String mergeColumn, boolean ascending)
TableDefinition(String name, TupleDefinition tdef, List<String> primaryKey)	Used when creating an empty table via sql.

Uses of StreamSqlException in org.yamcs.yarch.rocksdb

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

Modifier and Type	Method	Description
void	SecondaryIndexTableWalker.walk(TableVisitor visitor)	Iterate data through the given interval taking into account also the tableRange.
protected boolean	RdbTableWalker.walkInterval(PartitionManager.Interval interval, DbRange tableRange, TableVisitor visitor)	Iterate data through the given interval taking into account also the tableRange.

Uses of StreamSqlException in org.yamcs.yarch.streamsql

Subclasses of StreamSqlException in org.yamcs.yarch.streamsql

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

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

Modifier and Type	Method	Description
void	AndExpression.addFilter(FilterableTarget tableStream)
void	Expression.addFilter(FilterableTarget tableStream)	add a filter to the table if applicable.
void	InExpression.addFilter(FilterableTarget tableStream)
void	OrExpression.addFilter(FilterableTarget tableStream)
void	RelationalExpression.addFilter(FilterableTarget tableStream)
void	TableWalkerBuilder.addInFilter(ColumnExpression cexpr, boolean negation, Set<Object> values)	currently adds only filters on value based partitions
void	TupleSourceExpression.addInFilter(ColumnExpression cexpr, boolean negation, Set<Object> values)
Expression	StreamSqlParser.AdditiveExpression()
AddOp	StreamSqlParser.AddOp()
void	TableWalkerBuilder.addRelOpFilter(ColumnExpression cexpr, RelOp relOp, Object value)
void	TupleSourceExpression.addRelOpFilter(ColumnExpression cexpr, RelOp relOp, Object value)
boolean	HistogramStreamBuilder.addRelOpFilterHistogram(ColumnExpression cexpr, RelOp relOp, Object value)
protected abstract void	CompilableAggregateExpression.aggregateFillCode_newData(StringBuilder code)
AlterSequenceStatement	StreamSqlParser.AlterSequenceStatement()
Expression	StreamSqlParser.AndExpression()
void	StreamSqlParser.Argument()
void	StreamSqlParser.Arguments()
void	StreamSqlParser.BetweenClause()
void	AggregateExpression.bind(TupleDefinition def)
void	Expression.bind(TupleDefinition inputDef2)
void	SelectExpression.bind(ExecutionContext c)
void	SpeedLimitStreamExpression.bind(ExecutionContext c)
void	WindowSpecification.bind(TupleDefinition inputDef)
void	AggregateExpression.bindAggregate(TupleDefinition def)	When this is called, all the children are already bound.
BitwiseOp	StreamSqlParser.BitwiseOp()
CloseStreamStatement	StreamSqlParser.CloseStreamStatement()
void	StreamSqlParser.ColumnValue()
void	StreamSqlParser.ColumnValues()
CompiledExpression	AggregateExpression.compile()
CompiledExpression	ColumnExpression.compile()
CompiledExpression	Expression.compile()
CreateInputStreamStatement	StreamSqlParser.CreateInputStreamStatement()
CreateOutputStreamStatement	StreamSqlParser.CreateOutputStreamStatement()
CreateStreamStatement	StreamSqlParser.CreateStreamStatement()
CreateTableStatement	StreamSqlParser.CreateTableStatement()
DeleteStatement	StreamSqlParser.DeleteStatement()
DescribeStatement	StreamSqlParser.DescribeStatement()
void	AdditiveExpression.doBind()
protected void	AggregateListExpression.doBind()
void	AndExpression.doBind()
protected void	ArgumentExpression.doBind()
protected void	ArrayExpression.doBind()
void	BitwiseExpression.doBind()
void	ColumnExpression.doBind()
void	ExponentExpression.doBind()
protected abstract void	Expression.doBind()
protected void	FirstValExpression.doBind()
protected void	InExpression.doBind()
protected void	LikeExpression.doBind()
void	MultiplicativeExpression.doBind()
void	NegativeExpression.doBind()
void	NotExpression.doBind()
void	OrExpression.doBind()
void	RelationalExpression.doBind()
void	ValueExpression.doBind()
DropTableStatement	StreamSqlParser.DropTableStatement()
protected void	AlterSequenceStatement.execute(ExecutionContext context, Consumer<Tuple> consumer)
void	CloseStreamStatement.execute(ExecutionContext c, Consumer<Tuple> consumer)
protected void	CreateInputStreamStatement.execute(ExecutionContext context, Consumer<Tuple> consumer)
void	CreateOutputStreamStatement.execute(ExecutionContext c, Consumer<Tuple> consumer)
protected void	CreateStreamStatement.execute(ExecutionContext context, Consumer<Tuple> consumer)
protected void	CreateTableStatement.execute(ExecutionContext context, Consumer<Tuple> consumer)
protected void	DeleteStatement.execute(ExecutionContext context, Consumer<Tuple> consumer)
void	DescribeStatement.execute(ExecutionContext c, Consumer<Tuple> consumer)
protected void	DropTableStatement.execute(ExecutionContext context, Consumer<Tuple> consumer)
protected void	InsertStatement.execute(ExecutionContext context, Consumer<Tuple> consumer)
protected void	MergeStatement.execute(ExecutionContext context, Consumer<Tuple> consumer)
Stream	SelectExpression.execute(ExecutionContext c)
StreamSqlResult	SelectTableStatement.execute(ExecutionContext context)
void	SelectTableStatement.execute(ExecutionContext context, ResultListener resultListener, long limit)
protected void	ShowDatabasesStatement.execute(ExecutionContext context, Consumer<Tuple> consumer)
protected void	ShowSequencesStatement.execute(ExecutionContext context, Consumer<Tuple> consumer)
protected void	ShowStreamsStatement.execute(ExecutionContext context, Consumer<Tuple> consumer)
protected void	ShowStreamStatement.execute(ExecutionContext context, Consumer<Tuple> consumer)
protected void	ShowTablesStatement.execute(ExecutionContext context, Consumer<Tuple> consumer)
StreamSqlResult	SimpleStreamSqlStatement.execute(ExecutionContext c)
protected abstract void	SimpleStreamSqlStatement.execute(ExecutionContext context, Consumer<Tuple> consumer)
void	SimpleStreamSqlStatement.execute(ExecutionContext c, ResultListener resultListener, long limit)
Stream	SpeedLimitStreamExpression.execute(ExecutionContext c)
StreamSqlResult	StreamSqlStatement.execute(ExecutionContext context)	Execute query and return a result.
default void	StreamSqlStatement.execute(ExecutionContext context, ResultListener resultListener)	Execute query and send the results to the result listener.
void	StreamSqlStatement.execute(ExecutionContext context, ResultListener resultListener, long limit)	Execute query and limit the number of results returned.
protected void	UpdateTableStatement.execute(ExecutionContext context, Consumer<Tuple> consumer)
Expression	StreamSqlParser.ExponentExpression()
Expression	StreamSqlParser.Expression()
List<Expression>	StreamSqlParser.ExpressionList()
protected void	Expression.fillCode_Constructor(StringBuilder code)
protected void	InExpression.fillCode_Constructor(StringBuilder code)
protected void	ArrayExpression.fillCode_Declarations(StringBuilder code)
protected void	Expression.fillCode_Declarations(StringBuilder code)
protected void	Expression.fillCode_getValueBody(StringBuilder code)
protected void	InExpression.fillCode_getValueBody(StringBuilder code)
void	AdditiveExpression.fillCode_getValueReturn(StringBuilder code)
void	AggregateExpression.fillCode_getValueReturn(StringBuilder code)
void	AndExpression.fillCode_getValueReturn(StringBuilder code)
void	ArgumentExpression.fillCode_getValueReturn(StringBuilder code)
void	ArrayExpression.fillCode_getValueReturn(StringBuilder code)
void	BitwiseExpression.fillCode_getValueReturn(StringBuilder code)
void	ColumnExpression.fillCode_getValueReturn(StringBuilder code)
void	ExponentExpression.fillCode_getValueReturn(StringBuilder code)
abstract void	Expression.fillCode_getValueReturn(StringBuilder code)
void	InExpression.fillCode_getValueReturn(StringBuilder code)
void	LikeExpression.fillCode_getValueReturn(StringBuilder code)
void	MultiplicativeExpression.fillCode_getValueReturn(StringBuilder code)
void	NegativeExpression.fillCode_getValueReturn(StringBuilder code)
void	NotExpression.fillCode_getValueReturn(StringBuilder code)
void	OrExpression.fillCode_getValueReturn(StringBuilder code)
void	RelationalExpression.fillCode_getValueReturn(StringBuilder code)
void	ValueExpression.fillCode_getValueReturn(StringBuilder code)
Expression	StreamSqlParser.FunctionCall()
abstract CompiledAggregateExpression	AggregateExpression.getCompiledAggregate()
CompiledAggregateExpression	AggregateListExpression.getCompiledAggregate()
CompiledAggregateExpression	CompilableAggregateExpression.getCompiledAggregate()
CompiledAggregateExpression	FirstValExpression.getCompiledAggregate()
InClause	StreamSqlParser.InClause()
InsertStatement	StreamSqlParser.InsertAppendStatement()
InsertStatement	StreamSqlParser.InsertStatement()
void	StreamSqlParser.IntoClause()
void	StreamSqlParser.IsNullClause()
LikeClause	StreamSqlParser.LikeClause()
InsertStatement	StreamSqlParser.LoadStatement()
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()
Expression	StreamSqlParser.PrimaryExpression()
Expression	StreamSqlParser.RelationalExpression()
RelOp	StreamSqlParser.RelOp()
SelectExpression	StreamSqlParser.Select()
SelectExpression	StreamSqlParser.SelectExpression()
SelectItem	StreamSqlParser.SelectItem()
List<SelectItem>	StreamSqlParser.SelectList()
SelectTableStatement	StreamSqlParser.SelectTableStatement()
ShowDatabasesStatement	StreamSqlParser.ShowDatabasesStatement()
ShowEnginesStatement	StreamSqlParser.ShowEnginesStatement()
ShowSequencesStatement	StreamSqlParser.ShowSequencesStatement()
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()
TableColumnDefinition	StreamSqlParser.TableColumnDefinition()
void	StreamSqlParser.TableOption(CreateTableStatement cts)
TupleDefinition	StreamSqlParser.TupleDefinition()
TupleSourceExpression	StreamSqlParser.TupleSourceExpression()
Expression	StreamSqlParser.UnaryExpression()
Expression	StreamSqlParser.UnaryLogicalExpression()
UpdateTableStatement	StreamSqlParser.UpdateTableStatement()
InsertStatement	StreamSqlParser.UpsertAppendStatement()
InsertStatement	StreamSqlParser.UpsertStatement()
WindowSpecification	StreamSqlParser.WindowSpecification()

Uses of StreamSqlException in org.yamcs.yarch.streamsql.funct

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

Modifier and Type	Method	Description
protected void	CountExpression.aggregateFillCode_newData(StringBuilder code)
protected void	SumExpression.aggregateFillCode_newData(StringBuilder code)
protected void	CountExpression.doBind()
protected void	ExtractNumberExpression.doBind()
protected void	SubstringExpression.doBind()
protected void	SumExpression.doBind()
protected void	UnhexExpression.doBind()
void	ExtractNumberExpression.fillCode_getValueReturn(StringBuilder code)
void	SubstringExpression.fillCode_getValueReturn(StringBuilder code)
void	UnhexExpression.fillCode_getValueReturn(StringBuilder code)