Register a stream on the bottom layer topic with the same name as the stream. An exception will be thrown if the stream is already created.
CREATE STREAM stream_name [ AS select_query ] WITH (REPLICATE = INT);
stream_nameis a valid identifier.
select_queryis an optional
SELECT(Stream) query. For more information, see
<select_query>is specified, the created stream will be filled with records from the
SELECTquery continuously. Otherwise, the stream will only be created and kept empty.
CREATE STREAM weather WITH (FORMAT = "JSON"); CREATE STREAM abnormal_weather AS SELECT * FROM weather WHERE temperature > 30 AND humidity > 80 EMIT CHANGES WITH (FORMAT = "JSON");