Creating Streams

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

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

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

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

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

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

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

CREATE STREAM kin_stream ON example.order_stream
REFRESH EVERY 30 SECONDS
WITH OPTIONS (DATASINK_NAME = 'kin_dsink')

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')

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

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

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

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

CREATE STREAM kin_stream ON example.order_stream
WHERE cost > 10000
WITH OPTIONS (DATASINK_NAME = 'kin_dsink')

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