Package org.yamcs.yarch.streamsql

Class CreateTableStatement

java.lang.Object

org.yamcs.yarch.streamsql.CreateTableStatement

All Implemented Interfaces:

StreamSqlStatement

public class CreateTableStatement
extends Object
implements StreamSqlStatement

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	addHistogramColumn(String columnName)
void	execute(ExecutionContext c, ResultListener resultListener)
void	setCompressed(boolean c)
void	setEngine(String engine)
void	setPartitioning(PartitioningSpec pspec)
void	setTablespace(String tablespace)

Methods inherited from class java.lang.Object

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

Constructor Detail

CreateTableStatement

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

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

public void execute(ExecutionContext c,
                    ResultListener resultListener)
             throws StreamSqlException

Specified by:

execute in interface StreamSqlStatement

Throws:

StreamSqlException

setEngine

public void setEngine(String engine)