I build practical tools for Spark, streaming data, and observability.
- LakebaseForeachWriter — stream PySpark rows to Lakebase or PostgreSQL.
- spark-otel — OpenTelemetry for Spark and Databricks workloads.
- Databricks Hot Restart — redeploy Structured Streaming jobs with a short handoff.
- hydro — Python extensions for Spark and Delta Lake.




