# 流语句

用于创建和管理流的语句

# 创建流

CREATE STREAM 定义了一个连接到外部系统的数据流，以加载数据。

CREATE STREAM 
    stream_name 
    ( column_name <data_type> [ ,...n ] )
    WITH ( property_name = expression [, ...] );

1
2
3
4

详细的流语法和属性，请查看流。

示例:

CREATE STREAM my_stream ()
WITH ( datasource = "topic/temperature", FORMAT = "json", KEY = "id")

1
2

用于获取流定义的语句。

DESCRIBE STREAM stream_name

删除一个流。请确保所有涉及该流的规则都被删除。

DROP STREAM stream_name

展示所有定义的流。

SHOW STREAMS