Skip to content

Projects

Selected work

Three end-to-end projects showcasing streaming, lakehouse, and AI-assisted data engineering. Each repo runs locally with synthetic data, ships CI, and publishes measured results. The previews below are real artifacts from each project's demo path. Click any card for a live, interactive walkthrough of the architecture.

Streamlit fraud dashboard: KPI tiles, events-over-time line chart, and anomalies by kind

Project 01

Real-Time Fraud Signals Pipeline

Kafka -> Spark Structured Streaming -> Delta -> dbt -> Streamlit. Exactly-once processing, anomaly detection, dbt tests.

Streaming ingestion + watermarks · Data quality / dbt tests · Fraud analytics architecture

~110k/s detector throughput

  • Apache Kafka
  • Spark Structured Streaming
  • Delta Lake
  • dbt
  • Streamlit
Terminal capture of make demo: 50k CDRs generated, then Bronze, Silver, and Gold row counts

Project 02

Telecom Billing Lakehouse

Medallion (Bronze/Silver/Gold) lakehouse over synthetic CDR data. Airflow + MinIO + Iceberg + Great Expectations + dbt.

Medallion lakehouse design · Data contracts at the boundary · dbt modeling for BI

0.53s raw to Gold, 49,998 rows

  • Apache Airflow
  • Apache Iceberg
  • MinIO / S3
  • Great Expectations
  • dbt
Terminal capture of sql-optimizer analyze: color-coded analyzer findings table

Project 03

AI-Assisted SQL Optimizer

CLI that uses Claude to suggest Spark/Snowflake query rewrites and partition strategies. Benchmarked against a seeded corpus with explicit ground truth.

Applied LLM tooling · SQL parsing + heuristics · Benchmark methodology

0.67 keyword overlap vs ground truth

  • Python
  • Typer
  • Anthropic SDK
  • sqlglot
  • pytest