Aggregate and Avro Snap examples

Example Snaps used

Concatenate unique string values

This example pipeline demonstrates how to concatenate unique string values.

Count the occurrences of a given product name

This example pipeline demonstrates how to use the Aggregate Snap to count the occurrences of a given product name.

Sort input data and perform aggregate functions

This example pipeline demonstrates how to pre-sort the records with the Sort Snap and then perform the aggregate functions on each group using the Aggregate Snap.

Deserializing Avro data

This example pipeline demonstrates how to read an Avro file and convert it to a structured data format that can be used in downstream applications.

Transforming CSV data to Avro format

This example pipeline demonstrates how to convert CSV data to Avro format as per the specified schema and transform it to generate reports or update a database. The output is the transformed and formatted data ready for further processing.