Package org.yamcs.yarch.streamsql

Class TableWalkerBuilder

java.lang.Object

org.yamcs.yarch.streamsql.TableWalkerBuilder

All Implemented Interfaces:

FilterableTarget

public class TableWalkerBuilder
extends Object
implements FilterableTarget

Constructor Summary

Constructors

Constructor	Description
TableWalkerBuilder(ExecutionContext ctx, TableDefinition tableDefinition)

Method Summary

Modifier and Type	Method	Description
void	addInFilter(ColumnExpression cexpr, boolean negation, Set<Object> values)	currently adds only filters on value based partitions
void	addRelOpFilter(ColumnExpression cexpr, RelOp relOp, Object value)	Tries to add a restriction for the rows to be selected/updated/deleted.
TableWalker	build()
TableDefinition	getTableDefinition()
void	setAscending(boolean ascending)
void	setFollow(boolean follow)

Methods inherited from class java.lang.Object

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

Constructor Details

TableWalkerBuilder

public TableWalkerBuilder(ExecutionContext ctx,
 TableDefinition tableDefinition)

Method Details

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

currently adds only filters on value based partitions

Specified by:

addInFilter in interface FilterableTarget

Throws:

StreamSqlException

build

public TableWalker build()

setAscending

public void setAscending(boolean ascending)

setFollow

public void setFollow(boolean follow)

getTableDefinition

public TableDefinition getTableDefinition()