org.yamcs.yarch.streamsql

Class CreateTableStatement

java.lang.Object

org.yamcs.yarch.streamsql.StreamSqlStatement

org.yamcs.yarch.streamsql.CreateTableStatement

public class CreateTableStatement
extends StreamSqlStatement

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	addHistogramColumn(String columnName)
StreamSqlResult	execute(ExecutionContext c)
void	setCompressed(boolean c)
void	setDataDir(String dataDir)
void	setEngine(String engine)
void	setPartitioning(PartitioningSpec pspec)
void	setPartitionStorage(TableDefinition.PartitionStorage pstorage)

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

setDataDir

public void setDataDir(String dataDir)

setPartitioning

public void setPartitioning(PartitioningSpec pspec)

setCompressed

public void setCompressed(boolean c)

addHistogramColumn

public void addHistogramColumn(String columnName)

execute

public StreamSqlResult execute(ExecutionContext c)
                        throws StreamSqlException

Specified by:

execute in class StreamSqlStatement

Throws:

StreamSqlException

setEngine

public void setEngine(String engine)

setPartitionStorage

public void setPartitionStorage(TableDefinition.PartitionStorage pstorage)