Create Reltio object type streams in Snowflake
Learn how to create streams that have all changed (delta) data from the landing table.
Streams let Snowflake know when there is updated data in Reltio that needs to be loaded to a corresponding staging table. Create a stream for each Reltio object type: entities, relationships, interactions, matches, merges, and links.
- In the Snowflake application worksheet area, create a new SQL worksheet.
- In the SQL worksheet, run these commands to create a stream for each Reltio object type. Run each command individually and then check the result in step 3 before creating a stream for the next object type:
Entities stream Standard
Legacy (optional)CREATE STREAM "<database_name>"."<schema_name>"."entitiesStream" ON TABLE "<database_name>"."<schema_name>"."<landingtable_name>" APPEND_ONLY = true;
CREATE STREAM "<database_name>"."<schema_name>"."entities<entityType>OvStream" ON TABLE "<database_name>"."<schema_name>"."<landingtable_name>" APPEND_ONLY = true;
Relations stream CREATE STREAM "<database_name>"."<schema_name>"."relationsStream" ON TABLE "<database_name>"."<schema_name>"."<landingtable_name>" APPEND_ONLY = true;
Interactions stream CREATE STREAM "<database_name>"."<schema_name>"."interactionsStream" ON TABLE "<database_name>"."<schema_name>"."<landingtable_name>" APPEND_ONLY = true;
Matches stream CREATE STREAM "<database_name>"."<schema_name>"."matchesStream" ON TABLE "<database_name>"."<schema_name>"."<landingtable_name>" APPEND_ONLY = true;
Merges stream CREATE STREAM "<database_name>"."<schema_name>"."mergesStream" ON TABLE "<database_name>"."<schema_name>"."<landingtable_name>" APPEND_ONLY = true;
Links stream CREATE STREAM "<database_name>"."<schema_name>"."linksStream" ON TABLE "<database_name>"."<schema_name>"."<landingtable_name>" APPEND_ONLY = true;
where:-
<database_name>: Is the name of the database you created in Create a Snowflake database.
-
<schema_name>: Is the name of the schema you created in Create a Snowflake schema.
-
<landingtable_name>: Is the name of the landing data table you created in Create a landing data table in Snowflake.
<entityType>: Is the Reltio entity type you want to create streams for.
-
- In the SQL worksheet, view the Successfully created notification message.