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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CreateTableStatement.TableFormatOption

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)
void	addTableFormatOption(CreateTableStatement.TableFormatOption tfo)
protected void	execute(ExecutionContext context, Consumer<Tuple> consumer)
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 Details

CreateTableStatement

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

Method Details

setTablespace

public void setTablespace(String tablespace)

setPartitioning

public void setPartitioning(PartitioningSpec pspec)

addHistogramColumn

public void addHistogramColumn(String columnName)

addTableFormatOption

public void addTableFormatOption(CreateTableStatement.TableFormatOption tfo)

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)