Skip to content

Bringing semi-structured and unstructured data into governed Delta tables

Lakeflow Connect provides managed, no-code/low-code ingestion connectors that land data from SaaS applications, databases, and files directly into Unity Catalog-governed Delta tables, handling schema evolution and incremental refresh automatically. For semi-structured formats like JSON, Databricks stores nested structs, arrays, and maps natively in Delta's variant/struct columns, avoiding manual flattening at ingest time. Governance (access control, lineage, auditing) is enforced by Unity Catalog on the resulting Delta tables regardless of source connector.

1 · Learn the must-know

  • Lakeflow Connect ingestion pipelines write directly to Unity Catalog-managed Delta tables, so catalog, schema, and table permissions apply immediately without a separate registration step.
  • JSON and other semi-structured data can be ingested with schema inference and evolution enabled, letting nested fields (structs, arrays, maps) be preserved as native Delta types rather than flattened strings.
  • Auto Loader (cloudFiles) is the underlying incremental file-ingestion mechanism used for landing JSON, CSV, Parquet, and other files from cloud object storage into Delta tables, using checkpointing to track processed files exactly-once.
  • Unstructured or binary data (images, PDFs, etc.) is typically ingested using the binaryFile format, which stores file content plus metadata (path, modification time, length) as columns in a Delta table for downstream processing.
  • Managed connectors reduce the need for custom ETL code but still require defining a target catalog/schema and appropriate Unity Catalog permissions (USE CATALOG, USE SCHEMA, CREATE TABLE) before a pipeline can land data.
  • Schema drift in nested JSON (new or missing fields) is handled via schema evolution settings; ignoring this can cause pipeline failures or silently dropped columns if not configured correctly.

2 · Check your understanding

Check this objectiveFree · always available

A data engineering team needs to land nested JSON files from a partner SFTP-style cloud storage location into a Unity Catalog table, automatically evolve the schema as new fields appear, and avoid reprocessing files already loaded on each run. Which ingestion approach meets these requirements?

Your objective map0 tried · 0 answered correctly · 33 untouched

What you have tried across Databricks DEA's objectives, not a readiness score.

Databricks Intelligence Platform6% of the exam0 of 2 tried
Data Ingestion and Loading21% of the exam0 of 7 tried
Data Transformation and Modeling22% of the exam0 of 7 tried
Working with Lakeflow Jobs16% of the exam0 of 4 tried
Implementing CI/CD10% of the exam0 of 4 tried
Troubleshooting, Monitoring, and Optimization10% of the exam0 of 5 tried
Governance and Security15% of the exam0 of 4 tried

3 · Keep going