Accelerate the Value of Data

Create Reltio object type streams in Snowflake

Learn how to create streams that have all changed (delta) data from the landing table.

Before you create Reltio object-type streams in Snowflake, you must have created a landing data table. For more information, see topic Create a landing data table in Snowflake.

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.

To create Reltio object type streams in your Snowflake environment:
  1. In the Snowflake application worksheet area, create a new SQL worksheet.
  2. 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 streamStandard
    CREATE STREAM "<database_name>"."<schema_name>"."entitiesStream"
    ON TABLE "<database_name>"."<schema_name>"."<landingtable_name>"
    APPEND_ONLY = true;
    
    Legacy (optional)
    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:
  3. In the SQL worksheet, view the Successfully created notification message.
For general information, see Create object type streams in Snowflake SQL Command Reference.