Modifying Record Consolidation Transformations

While a mastering flow can contain multiple transformation steps, you typically need to modify only one of these steps: Consolidate Records. The Consolidate Records step applies transformation rules to produce a single record, called the mastered entity record (or golden record), that best represents a cluster. For most attributes, these rules select the most common value from the clustered source records.

If you added new output attributes in the Schema Mapping step, you also need to add transformation rules to select the appropriate values for each of these attributes in the mastered entity record.

Common transformation rules:

• To set the value to the most common value across source record:
  mode(<field>) as <field>
• To prefer a value from a specific source dataset across source records:
  mode(...filter(lambda x: <source_dataset> == preferred_source_for_other_attributes, array(<field>))) as <field>

If you require a more advanced rule to select the appropriate mastered entity record attribute value, see the Tamr Core transformations documentation for complete transformation function details. This link opens the Tamr Core documentation in a new window.

Note: Tamr Cloud supports scripted transformations for a single input dataset, resulting in a single output dataset.

To update transformations to consolidate records:

1. Navigate to Configurations > Data Products.

2. Select the data product.

3. Select the Configure Flow page.

4. Select the Consolidate Records step to open it.

5. For each new output attribute, add the transformation rule under //Groupby.

   Example: mode(<field>) as <field> to select the most common value for this attribute.

6. For each new output attribute, ensure that the the data type at the end of record consolidation is string type.

   Example:

   SELECT \*,  
   to_string(<field>) AS <field>
   

7. When you have finished the transformation updates, navigate back to the flow by selecting the back arrow next to the step description.