Skip to content

Examples

Each example is written three ways: as a YAML blueprint, with the declarative API and with the low-level API. Its page shows the versions in tabs.

Example What it shows YAML Declarative Low-level
Local Simulation prints events and telemetry, with no container local.yaml local_example.py local_example.py
Kafka Digital Twin takes updates from Kafka and publishes events and telemetry to Kafka kafka.yaml kafka_example.py kafka_example.py
Fast-Forward to Parquet a week generated at factor=0.0, written to Parquet parquet.yaml parquet_example.py parquet_example.py
Fast-Forward to Iceberg a day generated at factor=0.0, appended to an Iceberg table iceberg.yaml iceberg_example.py iceberg_example.py
Relational DB (Postgres) writes orders to PostgreSQL and takes updates from a table postgres.yaml postgres_example.py postgres_example.py
In-Memory Store (Redis) writes to a Redis Stream and takes updates from Pub/Sub redis.yaml redis_example.py redis_example.py
Backfill Then Go Live backdated history to Parquet, then live to Kafka backfill_live.yaml backfill_live_example.py backfill_live_example.py
Generate Related Records orders and their line items, in two PostgreSQL tables postgres_orders.yaml postgres_orders_example.py postgres_orders_example.py

Each example page says how to download and run it, and which odctl profile from Getting Started it needs.