org.yamcs.yarch.streamsql

Class Expression

java.lang.Object

org.yamcs.yarch.streamsql.Expression

Direct Known Subclasses:

AdditiveExpression, AggregateExpression, AndExpression, ColumnExpression, ExponentExpression, InExpression, LikeExpression, MultiplicativeExpression, NegativeExpression, NotExpression, OrExpression, RelationalExpression, ValueExpression

public abstract class Expression
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected Expression[]	children
protected boolean	constant
protected boolean	hasAggregates
protected TupleDefinition	inputDef
protected DataType	type

Constructor Summary

Constructors

Constructor and Description
Expression(Expression[] children)

Method Summary

Modifier and Type	Method and Description
Expression	addFilter(DbReaderStream tableStream) add a filter to the table if applicable and returns an expression where the condition is removed.
void	bind(TupleDefinition inputDef2)
void	collectAggregates(List<AggregateExpression> list)
CompiledExpression	compile()
protected abstract void	doBind()
protected void	fillCode_AllInputDefVars(StringBuilder code)
protected void	fillCode_Constructor(StringBuilder code)
protected void	fillCode_Declarations(StringBuilder code)
protected void	fillCode_getValueBody(StringBuilder code)
protected abstract void	fillCode_getValueReturn(StringBuilder code)
String	getColName() when the expression behaves like a column expression, this is the column name
DataType	getType()
protected boolean	isAggregate()
boolean	isConstant()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

type

protected DataType type

children

protected Expression[] children

inputDef

protected TupleDefinition inputDef

hasAggregates

protected boolean hasAggregates

constant

protected boolean constant

Constructor Detail

Expression

public Expression(Expression[] children)

Method Detail

isAggregate

protected boolean isAggregate()

isConstant

public final boolean isConstant()

addFilter

public Expression addFilter(DbReaderStream tableStream)
                     throws StreamSqlException

add a filter to the table if applicable and returns an expression where the condition is removed.

Parameters:

tableStream -

Returns:

Throws:

StreamSqlException

collectAggregates

public void collectAggregates(List<AggregateExpression> list)

doBind

protected abstract void doBind()
                        throws StreamSqlException

Throws:

StreamSqlException

bind

public void bind(TupleDefinition inputDef2)
          throws StreamSqlException

Throws:

StreamSqlException

getType

public DataType getType()

fillCode_Declarations

protected void fillCode_Declarations(StringBuilder code)

fillCode_Constructor

protected void fillCode_Constructor(StringBuilder code)
                             throws StreamSqlException

Throws:

StreamSqlException

fillCode_AllInputDefVars

protected void fillCode_AllInputDefVars(StringBuilder code)

fillCode_getValueBody

protected void fillCode_getValueBody(StringBuilder code)
                              throws StreamSqlException

Throws:

StreamSqlException

fillCode_getValueReturn

protected abstract void fillCode_getValueReturn(StringBuilder code)
                                         throws StreamSqlException

Throws:

StreamSqlException

compile

public CompiledExpression compile()
                           throws StreamSqlException

Throws:

StreamSqlException

getColName

public String getColName()

when the expression behaves like a column expression, this is the column name

Returns: