Examples
Runnable examples in crates/fungi-examples/.
Run
cargo run -p fungi-examples --example <name>
List
| Example | Demonstrates |
|---|---|
state_backend | Keyed state, snapshot/restore |
streaming_primitives | Watermarks, windows, timers |
execution_graph | DAG construction + topological sort |
checkpointing | Coordinator, barrier, store |
kafka_test | Kafka connectivity |
kafka_streaming | Streaming from Kafka |
kafka_pipeline | Pipeline with transforms |
kafka_sql | Kafka → SQL → Kafka |
kafka_sql (Full Pipeline)
# Setup Kafka
docker run -d --name kafka -p 9092:9092 apache/kafka:latest
docker exec kafka /opt/kafka/bin/kafka-topics.sh \
--create --topic events --bootstrap-server localhost:9092 \
--partitions 1 --replication-factor 1
# Run
cargo run -p fungi-examples --example kafka_sql
Output:
SQL Query Results:
Total amount by user:
user-1: 300
user-2: 300
Pipeline: Kafka → SQL → Kafka ✅
See Guides / Kafka for full Kafka setup.
Code Locations
| Example | File |
|---|---|
state_backend | crates/fungi-examples/examples/state_backend.rs |
streaming_primitives | crates/fungi-examples/examples/streaming_primitives.rs |
execution_graph | crates/fungi-examples/examples/execution_graph.rs |
checkpointing | crates/fungi-examples/examples/checkpointing.rs |
kafka_* | crates/fungi-examples/examples/kafka_*.rs |