Reanudar tras un reinicio
Tu canalización de streaming en Global Retail Analytics recoge nuevos archivos CSV desde un volumen de Unity Catalog y los escribe en Delta Lake. Tras una caída durante el fin de semana, el clúster se reinicia el lunes por la mañana. Llegaron tres archivos nuevos durante el fin de semana. El flujo procesa solo esos tres archivos: no se vuelven a cargar los de la semana anterior.
¿Qué permite que el flujo omita los archivos procesados previamente y reanude exactamente donde lo dejó?
Este ejercicio forma parte del curso
Transformación de datos con Spark SQL en Databricks
ejercicio interactivo práctico
Convierte la teoría en práctica con uno de nuestros ejercicios interactivos
Empezar ejercicio