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#

NameTypeDescription
<source_table_name>STRINGA 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.

See Also#