resume_data_stream()#
relationalai.<rai_schema>
#resume_data_stream(<source_table_name>)
Resumes a suspend Change Data Capture (CDC) data stream in specified RelationalAI (RAI) schema.
Requires the cdc_admin
or <rai_schema>_cdc
application role.
Parameters#
Name | Type | Description |
---|---|---|
<source_table_name> | STRING | A reference to the source table or view in Snowflake. |
Example#
Use resume_data_stream()
to resume a suspended CDC data stream within a specified RAI schema.
Replace <source_table_name>
with the fully-qualified name of the source table or view.
For example, to resume a stream for the table my_table
in the schema my_db.my_schema
:
#CALL relationalai.my_schema.resume_data_stream('my_db.my_schema.my_table');
Changes tracked while the stream was suspended are ingested once the stream is resumed. New changes to the source table or view are tracked and ingested as usual.