Uses of Class
org.yamcs.yarch.streamsql.StreamSqlException
-
Packages that use StreamSqlException Package Description org.yamcs org.yamcs.yarch 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 voidStreamInitializer. createStreams() -
Uses of StreamSqlException in org.yamcs.yarch
Methods in org.yamcs.yarch that throw StreamSqlException Modifier and Type Method Description booleanAbstractTableReaderStream. addInFilter(ColumnExpression cexpr, boolean negation, Set<Object> values)currently adds only filters on value based partitionsbooleanDbReaderStream. addInFilter(ColumnExpression cexpr, boolean negation, Set<Object> values)booleanAbstractTableReaderStream. addRelOpFilter(ColumnExpression cexpr, RelOp relOp, Object value)booleanDbReaderStream. addRelOpFilter(ColumnExpression cexpr, RelOp relOp, Object value)booleanHistogramReaderStream. addRelOpFilter(ColumnExpression cexpr, RelOp relOp, Object value)StreamSqlStatementYarchDatabaseInstance. createStatement(String query, Object... args)voidYarchDatabaseInstance. execute(String query, Object... args)voidYarchDatabaseInstance. execute(StreamSqlStatement stmt, ResultListener resultListener)voidTableDefinition. setHistogramColumns(List<String> histoColumns)voidTableDefinition. 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 columnvoidTableDefinition. 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 Description MergeStream(YarchDatabaseInstance ydb, Stream[] streams, String mergeColumn, boolean ascending)TableDefinition(String name, TupleDefinition tdef, List<String> primaryKey)Used when creating an "empty"(i.e. no enum values) table via sql. -
Uses of StreamSqlException in org.yamcs.yarch.streamsql
Subclasses of StreamSqlException in org.yamcs.yarch.streamsql Modifier and Type Class Description classColumnNotFoundExceptionclassGenericStreamSqlExceptionclassNotSupportedExceptionclassResourceNotFoundExceptionMethods in org.yamcs.yarch.streamsql that throw StreamSqlException Modifier and Type Method Description ExpressionAndExpression. addFilter(DbReaderStream tableStream)ExpressionExpression. addFilter(DbReaderStream tableStream)add a filter to the table if applicable and returns an expression where the condition is removed.ExpressionInExpression. addFilter(DbReaderStream tableStream)ExpressionOrExpression. addFilter(DbReaderStream tableStream)ExpressionRelationalExpression. addFilter(DbReaderStream tableStream)AddOpStreamSqlParser. AddOp()protected abstract voidCompilableAggregateExpression. aggregateFillCode_newData(StringBuilder code)protected voidSumExpression. aggregateFillCode_newData(StringBuilder code)ExpressionStreamSqlParser. AndExpression()voidStreamSqlParser. Argument()voidStreamSqlParser. Arguments()voidStreamSqlParser. BetweenClause()voidAggregateExpression. bind(TupleDefinition def)voidExpression. bind(TupleDefinition inputDef2)voidSelectExpression. bind(ExecutionContext c)voidSpeedLimitStreamExpression. bind(ExecutionContext c)voidWindowSpecification. bind(TupleDefinition inputDef)voidAggregateExpression. bindAggregate(TupleDefinition def)When this is called, all the children are already bound.CloseStreamStatementStreamSqlParser. CloseStreamStatement()voidStreamSqlParser. ColumnValue()voidStreamSqlParser. ColumnValues()CompiledExpressionAggregateExpression. compile()CompiledExpressionColumnExpression. compile()CompiledExpressionExpression. compile()CreateInputStreamStatementStreamSqlParser. CreateInputStreamStatement()CreateOutputStreamStatementStreamSqlParser. CreateOutputStreamStatement()CreateStreamStatementStreamSqlParser. CreateStreamStatement()CreateTableStatementStreamSqlParser. CreateTableStatement()DeleteStatementStreamSqlParser. DeleteStatement()DescribeStatementStreamSqlParser. DescribeStatement()voidAdditiveExpression. doBind()protected voidAggregateListExpression. doBind()voidAndExpression. doBind()voidColumnExpression. doBind()voidExponentExpression. doBind()protected abstract voidExpression. doBind()protected voidFirstValExpression. doBind()protected voidInExpression. doBind()protected voidLikeExpression. doBind()voidMultiplicativeExpression. doBind()voidNegativeExpression. doBind()voidNotExpression. doBind()voidOrExpression. doBind()voidRelationalExpression. doBind()protected voidSumExpression. doBind()voidValueExpression. doBind()DropTableStatementStreamSqlParser. DropTableStatement()voidCloseStreamStatement. execute(ExecutionContext c, ResultListener resultListener)voidCreateInputStreamStatement. execute(ExecutionContext c, ResultListener resultListener)voidCreateOutputStreamStatement. execute(ExecutionContext c, ResultListener resultListener)voidCreateStreamStatement. execute(ExecutionContext c, ResultListener listener)voidCreateTableStatement. execute(ExecutionContext c, ResultListener resultListener)voidDeleteStatement. execute(ExecutionContext c, ResultListener listener)voidDescribeStatement. execute(ExecutionContext c, ResultListener resultListener)voidDropTableStatement. execute(ExecutionContext c, ResultListener resultListener)voidInsertStatement. execute(ExecutionContext c, ResultListener resultListener)voidMergeStatement. execute(ExecutionContext c, ResultListener resultListener)StreamSelectExpression. execute(ExecutionContext c)voidSelectTableStatement. execute(ExecutionContext c, ResultListener resultListener)voidShowDatabasesStatement. execute(ExecutionContext c, ResultListener resultListener)voidShowEnginesStatement. execute(ExecutionContext c, ResultListener resultListener)voidShowStreamsStatement. execute(ExecutionContext c, ResultListener resultListener)voidShowStreamStatement. execute(ExecutionContext c, ResultListener resultListener)voidShowTablesStatement. execute(ExecutionContext c, ResultListener resultListener)StreamSpeedLimitStreamExpression. execute(ExecutionContext c)voidStreamSqlStatement. execute(ExecutionContext c, ResultListener resultListener)ExpressionStreamSqlParser. ExponentExpression()ExpressionStreamSqlParser. Expression()List<Expression>StreamSqlParser. ExpressionList()protected voidExpression. fillCode_Constructor(StringBuilder code)protected voidInExpression. fillCode_Constructor(StringBuilder code)protected voidExpression. fillCode_getValueBody(StringBuilder code)protected voidInExpression. fillCode_getValueBody(StringBuilder code)voidAdditiveExpression. fillCode_getValueReturn(StringBuilder code)voidAggregateExpression. fillCode_getValueReturn(StringBuilder code)voidAndExpression. fillCode_getValueReturn(StringBuilder code)voidColumnExpression. fillCode_getValueReturn(StringBuilder code)voidExponentExpression. fillCode_getValueReturn(StringBuilder code)abstract voidExpression. fillCode_getValueReturn(StringBuilder code)voidInExpression. fillCode_getValueReturn(StringBuilder code)voidLikeExpression. fillCode_getValueReturn(StringBuilder code)voidMultiplicativeExpression. fillCode_getValueReturn(StringBuilder code)voidNegativeExpression. fillCode_getValueReturn(StringBuilder code)voidNotExpression. fillCode_getValueReturn(StringBuilder code)voidOrExpression. fillCode_getValueReturn(StringBuilder code)voidRelationalExpression. fillCode_getValueReturn(StringBuilder code)voidValueExpression. fillCode_getValueReturn(StringBuilder code)List<Expression>StreamSqlParser. FunctionArgumentList()ExpressionStreamSqlParser. FunctionCall()abstract CompiledAggregateExpressionAggregateExpression. getCompiledAggregate()CompiledAggregateExpressionAggregateListExpression. getCompiledAggregate()CompiledAggregateExpressionCompilableAggregateExpression. getCompiledAggregate()CompiledAggregateExpressionFirstValExpression. getCompiledAggregate()InClauseStreamSqlParser. InClause()InsertStatementStreamSqlParser. InsertAppendStatement()InsertStatementStreamSqlParser. InsertStatement()voidStreamSqlParser. IntoClause()voidStreamSqlParser. IsNullClause()LikeClauseStreamSqlParser. LikeClause()org.yamcs.yarch.streamsql.MergeExpressionStreamSqlParser. MergeExpression()ExpressionStreamSqlParser. MultiplicativeExpression()MultOpStreamSqlParser. MultOp()BigDecimalStreamSqlParser. NumericConstant()StringStreamSqlParser. ObjectName()StreamSqlStatementStreamSqlParser. OneStatement()booleanStreamSqlParser. OrderClause()PartitioningSpecStreamSqlParser. PartitioningSpec()ExpressionStreamSqlParser. PrimaryExpression()ExpressionStreamSqlParser. RelationalExpression()RelOpStreamSqlParser. RelOp()SelectExpressionStreamSqlParser. Select()SelectExpressionStreamSqlParser. SelectExpression()SelectItemStreamSqlParser. SelectItem()List<SelectItem>StreamSqlParser. SelectList()SelectTableStatementStreamSqlParser. SelectTableStatement()ShowDatabasesStatementStreamSqlParser. ShowDatabasesStatement()ShowEnginesStatementStreamSqlParser. ShowEnginesStatement()ShowStreamsStatementStreamSqlParser. ShowStreamsStatement()ShowStreamStatementStreamSqlParser. ShowStreamStatement()ShowTablesStatementStreamSqlParser. ShowTablesStatement()ExpressionStreamSqlParser. SimpleExpression()SpeedLimitStreamExpressionStreamSqlParser. SpeedLimitStreamExpression()SpeedSpecStreamSqlParser. SpeedSpec()org.yamcs.yarch.streamsql.StreamExpressionStreamSqlParser. StreamExpression()StreamSqlStatementStreamSqlParser. StreamSqlStatement()voidStreamSqlParser. TableOption(CreateTableStatement cts)TupleDefinitionStreamSqlParser. TupleDefinition()TupleSourceExpressionStreamSqlParser. TupleSourceExpression()ExpressionStreamSqlParser. UnaryExpression()ExpressionStreamSqlParser. UnaryLogicalExpression()InsertStatementStreamSqlParser. UpsertAppendStatement()InsertStatementStreamSqlParser. UpsertStatement()WindowSpecificationStreamSqlParser. 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 voidExtractNumberExpression. doBind()protected voidSubstringExpression. doBind()protected voidUnhexExpression. doBind()voidExtractNumberExpression. fillCode_getValueReturn(StringBuilder code)voidSubstringExpression. fillCode_getValueReturn(StringBuilder code)voidUnhexExpression. fillCode_getValueReturn(StringBuilder code)
-