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

Packages that use StreamSqlException

Package	Description
org.yamcs
org.yamcs.yarch
org.yamcs.yarch.query
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

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

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

Modifier and Type	Method	Description
StreamSqlStatement	CreateStreamQueryBuilder.toStatement()
StreamSqlStatement	CreateTableQueryBuilder.toStatement()
StreamSqlStatement	InsertIntoTableQueryBuilder.toStatement()
StreamSqlStatement	QueryBuilder.toStatement()
StreamSqlStatement	SelectStreamQueryBuilder.toStatement()
StreamSqlStatement	UpdateTableQueryBuilder.toStatement()

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)
final Expression	StreamSqlParser.AdditiveExpression()
final 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)
final AlterSequenceStatement	StreamSqlParser.AlterSequenceStatement()
final AlterTableStatement	StreamSqlParser.AlterTableStatement()
final Expression	StreamSqlParser.AndExpression()
final void	StreamSqlParser.Argument()
final void	StreamSqlParser.Arguments()
final void	StreamSqlParser.BetweenClause()
void	AggregateExpression.bind(TupleDefinition def)
void	Expression.bind(TupleDefinition inputDef2)
void	InsertValuesExpression.bind(ExecutionContext c)
void	SelectExpression.bind(ExecutionContext c)
void	WindowSpecification.bind(TupleDefinition inputDef)
void	AggregateExpression.bindAggregate(TupleDefinition def)	When this is called, all the children are already bound.
final BitwiseOp	StreamSqlParser.BitwiseOp()
final CloseStreamStatement	StreamSqlParser.CloseStreamStatement()
CompiledExpression	AggregateExpression.compile()
CompiledExpression	ColumnExpression.compile()
CompiledExpression	Expression.compile()
final CreateInputStreamStatement	StreamSqlParser.CreateInputStreamStatement()
final CreateStreamStatement	StreamSqlParser.CreateStreamStatement()
final CreateTableStatement	StreamSqlParser.CreateTableStatement()
final DeleteStatement	StreamSqlParser.DeleteStatement()
final 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	IsNullExpression.doBind()
protected void	LikeExpression.doBind()
void	MultiplicativeExpression.doBind()
void	NegativeExpression.doBind()
void	NotExpression.doBind()
void	NullExpression.doBind()
void	OrExpression.doBind()
void	RelationalExpression.doBind()
void	ValueExpression.doBind()
final DropTableStatement	StreamSqlParser.DropTableStatement()
protected void	AlterSequenceStatement.execute(ExecutionContext context, Consumer<Tuple> consumer)
protected void	AlterTableStatement.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)
Stream	InsertValuesExpression.execute(ExecutionContext c)
protected void	MergeStatement.execute(ExecutionContext context, Consumer<Tuple> consumer)
Stream	SelectExpression.execute(ExecutionContext c)
StreamSqlResult	SelectTableStatement.execute(YarchDatabaseInstance ydb)
void	SelectTableStatement.execute(YarchDatabaseInstance ydb, 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)
protected abstract void	SimpleStreamSqlStatement.execute(ExecutionContext context, Consumer<Tuple> consumer)
StreamSqlResult	SimpleStreamSqlStatement.execute(YarchDatabaseInstance ydb)
void	SimpleStreamSqlStatement.execute(YarchDatabaseInstance ydb, ResultListener resultListener, long limit)
StreamSqlResult	StreamSqlStatement.execute(YarchDatabaseInstance ydb)	Execute query and return a result.
default void	StreamSqlStatement.execute(YarchDatabaseInstance ydb, ResultListener resultListener)	Execute query and send the results to the result listener.
void	StreamSqlStatement.execute(YarchDatabaseInstance ydb, ResultListener resultListener, long limit)	Execute query and limit the number of results returned.
protected void	UpdateTableStatement.execute(ExecutionContext context, Consumer<Tuple> consumer)
final Expression	StreamSqlParser.ExponentExpression()
final Expression	StreamSqlParser.Expression()
final 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	IsNullExpression.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	NullExpression.fillCode_getValueReturn(StringBuilder code)
void	OrExpression.fillCode_getValueReturn(StringBuilder code)
void	RelationalExpression.fillCode_getValueReturn(StringBuilder code)
void	ValueExpression.fillCode_getValueReturn(StringBuilder code)
final Expression	StreamSqlParser.FunctionCall()
abstract CompiledAggregateExpression	AggregateExpression.getCompiledAggregate()
CompiledAggregateExpression	AggregateListExpression.getCompiledAggregate()
CompiledAggregateExpression	CompilableAggregateExpression.getCompiledAggregate()
CompiledAggregateExpression	FirstValExpression.getCompiledAggregate()
final InClause	StreamSqlParser.InClause()
final InsertStatement	StreamSqlParser.InsertStatement()
final void	StreamSqlParser.IntoClause()
final IsNullClause	StreamSqlParser.IsNullClause()
final LikeClause	StreamSqlParser.LikeClause()
final org.yamcs.yarch.streamsql.MergeExpression	StreamSqlParser.MergeExpression()
final Expression	StreamSqlParser.MultiplicativeExpression()
final MultOp	StreamSqlParser.MultOp()
final BigDecimal	StreamSqlParser.NumericConstant()
final String	StreamSqlParser.ObjectName()
final StreamSqlStatement	StreamSqlParser.OneStatement()
final boolean	StreamSqlParser.OrderClause()
final PartitioningSpec	StreamSqlParser.PartitioningSpec()
final Expression	StreamSqlParser.PrimaryExpression()
final Expression	StreamSqlParser.RelationalExpression()
final RelOp	StreamSqlParser.RelOp()
final SelectExpression	StreamSqlParser.Select()
final SelectExpression	StreamSqlParser.SelectExpression()
final SelectItem	StreamSqlParser.SelectItem()
final List<SelectItem>	StreamSqlParser.SelectList()
final SelectTableStatement	StreamSqlParser.SelectTableStatement()
final ShowDatabasesStatement	StreamSqlParser.ShowDatabasesStatement()
final ShowEnginesStatement	StreamSqlParser.ShowEnginesStatement()
final ShowSequencesStatement	StreamSqlParser.ShowSequencesStatement()
final ShowStreamsStatement	StreamSqlParser.ShowStreamsStatement()
final ShowStreamStatement	StreamSqlParser.ShowStreamStatement()
final ShowTablesStatement	StreamSqlParser.ShowTablesStatement()
final Expression	StreamSqlParser.SimpleExpression()
final org.yamcs.yarch.streamsql.StreamExpression	StreamSqlParser.StreamExpression()
final StreamSqlStatement	StreamSqlParser.StreamSqlStatement()
final TableColumnDefinition	StreamSqlParser.TableColumnDefinition()
final CreateTableStatement.TableFormatOption	StreamSqlParser.TableFormatOption()
final void	StreamSqlParser.TableOption(CreateTableStatement cts)
final TupleDefinition	StreamSqlParser.TupleDefinition()
final TupleSourceExpression	StreamSqlParser.TupleSourceExpression()
final Expression	StreamSqlParser.UnaryExpression()
final Expression	StreamSqlParser.UnaryLogicalExpression()
final UpdateTableStatement	StreamSqlParser.UpdateTableStatement()
final WindowSpecification	StreamSqlParser.WindowSpecification()

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

Modifier	Constructor	Description
	InsertValuesExpression(List<String> columns, List<SelectItem> selectList)

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	CoalesceExpression.doBind()
protected void	CountExpression.doBind()
protected void	ExtractNumberExpression.doBind()
protected void	SubstringExpression.doBind()
protected void	SumExpression.doBind()
protected void	UnhexExpression.doBind()
void	CoalesceExpression.fillCode_getValueReturn(StringBuilder code)
void	ExtractNumberExpression.fillCode_getValueReturn(StringBuilder code)
void	SubstringExpression.fillCode_getValueReturn(StringBuilder code)
void	UnhexExpression.fillCode_getValueReturn(StringBuilder code)