Creating Streams

Copy-paste examples of how to create streams with SQL

Several authentication schemes across multiple consumers are supported. For a detailed overview of all of the consumer-specific options, see the SQL documentation.


Monitor Target

Data Sink 
1
2

CREATE STREAM kin_stream ON example.order_stream
WITH OPTIONS (DATASINK_NAME = 'kin_dsink')
Kafka (No Auth) 
1
2
3
4
5
6

CREATE STREAM kin_stream ON example.order_stream
WITH OPTIONS
(
    DESTINATION = 'kafka://kafka-test:9092',
    KAFKA_TOPIC_NAME = 'kafka-test'
)
Local Table 
1
2

CREATE STREAM kin_stream ON example.order_stream
WITH OPTIONS (DESTINATION = 'table://example.order_target')
HTTP 
1
2

CREATE STREAM kin_stream ON example.order_stream
WITH OPTIONS (DESTINATION = 'http://localhost:8080')
HTTPS 
1
2

CREATE STREAM kin_stream ON example.order_stream
WITH OPTIONS (DESTINATION = 'https://localhost:8088')

Refresh

On Change (default) 
1
2

CREATE STREAM kin_stream ON example.order_stream
WITH OPTIONS (DATASINK_NAME = 'kin_dsink')
On Change (explicit) 
1
2
3

CREATE STREAM kin_stream ON example.order_stream
REFRESH ON CHANGE
WITH OPTIONS (DATASINK_NAME = 'kin_dsink')
Scheduled 
1
2
3

CREATE STREAM kin_stream ON example.order_stream
REFRESH EVERY 30 SECONDS
WITH OPTIONS (DATASINK_NAME = 'kin_dsink')
Scheduled w/ Start Time 
1
2
3

CREATE STREAM kin_stream ON example.order_stream
REFRESH EVERY 1 MINUTE STARTING AT '2025-02-25 02:25:00'
WITH OPTIONS (DATASINK_NAME = 'kin_dsink')

Event

Insert (default) 
1
2

CREATE STREAM kin_stream ON example.order_stream
WITH OPTIONS (DATASINK_NAME = 'kin_dsink')
Insert (explicit) 
1
2
3
4
5
6

CREATE STREAM kin_stream ON example.order_stream
WITH OPTIONS
(
    DATASINK_NAME = 'kin_dsink',
    EVENT = 'insert'
)
Update 
1
2
3
4
5
6

CREATE STREAM kin_stream ON example.order_stream
WITH OPTIONS
(
    DATASINK_NAME = 'kin_dsink',
    EVENT = 'update'
)
Delete 
1
2
3
4
5
6

CREATE STREAM kin_stream ON example.order_stream
WITH OPTIONS
(
    DATASINK_NAME = 'kin_dsink',
    EVENT = 'delete'
)

Options

Filter 
1
2
3

CREATE STREAM kin_stream ON example.order_stream
WHERE cost > 10000
WITH OPTIONS (DATASINK_NAME = 'kin_dsink')
Increasing Column 
1
2
3
4
5
6

CREATE STREAM kin_stream ON example.order_stream
WITH OPTIONS
(
    DATASINK_NAME = 'kin_dsink',
    INCREASING_COLUMN = 'order_id'
)