Package org.yamcs.yarch.streamsql

Class CreateTableStatement

java.lang.Object

org.yamcs.yarch.streamsql.SimpleStreamSqlStatement

org.yamcs.yarch.streamsql.CreateTableStatement

All Implemented Interfaces:

StreamSqlStatement

public class CreateTableStatement
extends SimpleStreamSqlStatement

Constructor Summary

Constructors

Constructor	Description
CreateTableStatement(boolean ifNotExists, String tableName, TupleDefinition tupleDefinition, List<String> primaryKey, List<String> index)

Method Summary

Modifier and Type	Method	Description
void	addHistogramColumn(String columnName)
protected void	execute(ExecutionContext context, Consumer<Tuple> consumer)
void	setCompressed(boolean c)
void	setEngine(String engine)
void	setPartitioning(PartitioningSpec pspec)
void	setTablespace(String tablespace)

Methods inherited from class org.yamcs.yarch.streamsql.SimpleStreamSqlStatement

execute, execute, getResultDefinition

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.yamcs.yarch.streamsql.StreamSqlStatement

execute

Constructor Detail

CreateTableStatement

public CreateTableStatement(boolean ifNotExists,
                            String tableName,
                            TupleDefinition tupleDefinition,
                            List<String> primaryKey,
                            List<String> index)

Method Detail

setTablespace

public void setTablespace(String tablespace)

setPartitioning

public void setPartitioning(PartitioningSpec pspec)

setCompressed

public void setCompressed(boolean c)

addHistogramColumn

public void addHistogramColumn(String columnName)

execute

protected void execute(ExecutionContext context,
                       Consumer<Tuple> consumer)
                throws StreamSqlException

Specified by:

execute in class SimpleStreamSqlStatement

Throws:

StreamSqlException

setEngine

public void setEngine(String engine)