Stream Workers Examples

This section provides examples of stream workers that you can use to learn or to create your own.

🗃️ Basic Examples

5 items

🗃️ Correlating Events

3 items

🗃️ Enriching Data

3 items

📄️ Data Pipeline Examples

This page explains ways to create data pipelines.

📄️ Data Cleaning Examples

This page shows examples of ways to clean your data.

📄️ Data Transformation Examples

This page explains ways to transform your data.

📄️ Consuming Data Example

This stream worker consumes all data from ConsumerSalesTotalsStream and then sends it to PublishSalesTotalsStream. The stream worker includes an optional sink and query, currently commented out, for testing.

📄️ Consuming Messages in Different Formats

This page shows you examples of different ways to map stream worker messages to change how messages are consumed.

📄️ Publishing Data in Different Formats

In this example, the stream worker ingests JSON events, groups them by product, and publishes the data in text format.

📄️ Null Handling Examples

This page provides examples of using nulls in stream workers.