Bulk load records

This example pipeline demonstrates how to update a record using the Snowflake Bulk Upsert Snap, routing invalid records that cannot be inserted to an error view.


Pipeline for Bulk Load Records

In the pipeline execution:

  1. The Mapper (Data) Snap maps the record details to the input fields of Snowflake Upsert Snap:
    Snowflake Select
  2. Snowflake Upsert Snap updates the record using the "PUBLIC"."Persons" table object:
  3. Successful execution of the pipeline displays the following data preview (Note that one input has been made and two records with the name P_ID have been updated within the Persons table.):