| Ingest files landing in S3, ADLS, or GCS using Databricks Autoloader | Autoloader / Cloud Files |
| Ingest from Kafka or Azure Event Hubs | Kafka & Event Hubs |
| CDC merge — Type 1 or Type 2 SCD from a change-data-capture source | CDC with apply_changes |
| Full snapshot ingestion — replace-all semantics, not streaming | Snapshot Ingestion |
| Fan-out: one bronze table as source for multiple silver tables | Silver Fanout |
| Write pipeline output to an external Delta table or Kafka topic | DLT Sink |
| Multiple source paths (e.g. US, EU, APAC) → single target table | Multi-Source CDC |
| Filter rows at pipeline time by column value | Row Filters |