Package org.yamcs.yarch.streamsql

Class TupleSourceExpression

java.lang.Object

org.yamcs.yarch.streamsql.TupleSourceExpression

All Implemented Interfaces:

FilterableTarget

public class TupleSourceExpression
extends Object
implements FilterableTarget

A source of tuples. Can be:

• a reference to an existing stream objectName
• a reference to a table objectName
• a stream expression

Constructor Summary

Constructors

Constructor	Description
TupleSourceExpression(String name)
TupleSourceExpression(org.yamcs.yarch.streamsql.StreamExpression expr)

Method Summary

Modifier and Type	Method	Description
void	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	addRelOpFilter(ColumnExpression cexpr, RelOp relOp, Object value)	Tries to add a restriction for the rows to be selected/updated/deleted.
boolean	isFinite()
void	setAscending(boolean ascending)
void	setFollow(boolean follow)
void	setHistogramColumn(String histoColumn)
void	setHistogramMergeTime(BigDecimal mergeTime)

Methods inherited from class java.lang.Object

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

Constructor Details

TupleSourceExpression

public TupleSourceExpression(String name)

TupleSourceExpression

public TupleSourceExpression(org.yamcs.yarch.streamsql.StreamExpression expr)

Method Details

setHistogramColumn

public void setHistogramColumn(String histoColumn)

addRelOpFilter

public void addRelOpFilter(ColumnExpression cexpr,
 RelOp relOp,
 Object value)
                    throws StreamSqlException

Description copied from interface: FilterableTarget

Tries to add a restriction for the rows to be selected/updated/deleted. This will implement optimisations to avoid scanning the table row by row.

Typically it works if the condition refers to the primary key.

Specified by:

addRelOpFilter in interface FilterableTarget

Throws:

StreamSqlException

addInFilter

public void addInFilter(ColumnExpression cexpr,
 boolean negation,
 Set<Object> values)
                 throws StreamSqlException

Description copied from interface: FilterableTarget

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

Specified by:

addInFilter in interface FilterableTarget

Throws:

StreamSqlException

setHistogramMergeTime

public void setHistogramMergeTime(BigDecimal mergeTime)

setAscending

public void setAscending(boolean ascending)

setFollow

public void setFollow(boolean follow)

isFinite

public boolean isFinite()