Real-Time Fraud Signals Pipeline
repoKafka -> Spark Structured Streaming -> Delta -> dbt -> Streamlit. Exactly-once processing, anomaly detection, dbt tests.
- Apache Kafka
- Spark Structured Streaming
- Delta Lake
- dbt
- Streamlit
- Python
Senior Data / Analytics Engineer
Alex Huggler
I build production data platforms — streaming pipelines, lakehouse architectures, and analytics that move the needle on revenue and risk.
$900K/yr
Fraud-loss reduction delivered
$2.2B
Portfolio under analytics ownership
6 yrs
At AT&T, Azure + Databricks stack
About
Senior data and analytics engineer with six years at AT&T building production data platforms on Azure and Databricks. I work the full stack from PySpark ingestion through dbt analytics models to BI delivery, with a focus on streaming, data quality, and turning ambiguous business problems into tractable pipelines. Microsoft DP-203 (Data Engineering) and DP-100 (AI Engineering) certified.
Current focus
- →Streaming + lakehouse architectures (Spark, Delta, Iceberg)
- →Cloud data platforms on Azure and AWS
- →Analytics engineering with dbt + data contracts
- →Applied AI for data engineering productivity
Stack
- PySpark
- Databricks
- Azure Data Factory
- Delta Lake
- Apache Iceberg
- Snowflake
- dbt
- Apache Airflow
- Apache Kafka
- Python
- SQL
- Terraform
Featured projects
All projects →Telecom Billing Lakehouse
repoMedallion (Bronze/Silver/Gold) lakehouse over synthetic CDR data. Airflow + MinIO + Iceberg + Great Expectations + dbt.
- Apache Airflow
- Apache Iceberg
- MinIO / S3
- Great Expectations
- dbt
- Terraform
AI-Assisted SQL Optimizer
repoCLI that uses Claude to suggest Spark/Snowflake query rewrites and partition strategies. Benchmarked against a 50-query corpus.
- Python
- Typer
- Anthropic SDK
- sqlglot
- pytest