STREAM
Config path: /<database>/<schema>/stream/<name>.yaml
Example:
Schema
object_type (str) - object type for stream (e.g.
TABLE
,EXTERNAL_TABLE
)object_name (ident) - object name for stream
append_only (bool) - is stream
APPEND_ONLY
(forTABLE
)insert_only (bool) - is stream
INSERT_ONLY
(forEXTERNAL_TABLE
)show_initial_rows (bool) - return existing rows when the stream is consumed for the first time
comment (str)
Usage notes
If stream is created on top of
TABLE
, table should haveCHANGE_TRACKING=TRUE
set explicitly in config. Otherwise SnowDDL will try to removeCHANGE_TRACKING
during next run.If stream is re-created, the contents of stream will lost.
Links
Last updated