This repository offers a comprehensive range of dataflow examples from basic to advanced levels, designed to familiarize you with the concepts and techniques essential for deploying Stateful Dataflows.
-
Install and Updated Rust
curl --proto '=https' --tlsv1.2 -sSf https://sh.rustup.rs | sh rustup update
-
Install Fluvio and SDF
curl -fsS https://hub.infinyon.cloud/install/install.sh | bash fvm install sdf-beta4 -
Start Cluster
fluvio cluster start
Dataflow examples:
- bank-processing
- car-processing
- hackernews-notify
- helsinki-transit
- http-callout
- mask-user-pii
- openai-callout
- split-sentence
- word-counter
- word-probe
Examples centered around primitive concepts and operations.
- map
- filter
- filter-map
- flat-map
- split (filter)
- split (filter-map)
- merge
- regex
- sql (cli)
- sql (join)
- update-state
- key-value (input)
- key-value (output)
- key-value (chained)
Step-by-step instructions on how to build your own package:
Pre-built packages used in dataflows: