Consulente Certificato Databricks specializzato nella costruzione di piattaforme dati scalabili, sicure e ottimizzate per i costi.
# Implementazione Delta Lake
df.writeStream \
.format("delta") \
.outputMode("append") \
.option("checkpointLocation", path) \
.toTable("silver_events")
Ingestione dati grezzi in formato Delta. Utilizzo di Auto Loader per gestire stream di file da S3/Azure Blob Storage in modo incrementale.
Filtering, cleaning e join. Implementazione di Schema Enforcement e validazione della qualità del dato per garantire affidabilità .
Tabelle aggregate e ottimizzate per BI/ML. Utilizzo di Liquid Clustering e Z-Order per query ultra-veloci.
Anche se i progetti aziendali sono sotto NDA, mantengo repository pubblici dove implemento architetture di test, ottimizzazione Spark e benchmark.
Visita il mio GitHub Portfolio