Noos
PT EN
RAN-DBDEA-00014
Ranvier · DBDEA

Prova DBDEA Tópicos: ingestion Dificuldade: easy A questão está em en.

A team copies this snippet from an old tutorial to ingest JSON files that keep arriving in a Unity Catalog volume: ```python df = (spark.read .format("cloudFiles") .option("cloudFiles.format", "json") .load("/Volumes/main/ingest/events/")) ``` The job runs on a schedule, but each run never picks up files that arrived after the very first execution, and no schema inference is configured. Which change turns this into a working Auto Loader stream with schema inference and evolution?

Alternativas (Modo Leitura) Clique para filtrar a discussão →
  1. A. Switch the reader to spark.readStream.format("cloudFiles") and keep everything else unchanged, because schema inference needs no additional options
  2. B. Keep spark.read and add .option("cloudFiles.schemaLocation", ...) to the reader, since the batch reader supports Auto Loader options too
  3. C. Use spark.readStream.format("cloudFiles") with cloudFiles.format and a durable cloudFiles.schemaLocation for schema inference and evolution
  4. D. Replace format("cloudFiles") with format("streamingFiles") and set checkpointLocation on the reader, because schemaLocation only applies to Delta targets
Revelar gabarito

Resposta correta: Use spark.readStream.format("cloudFiles") with cloudFiles.format and a durable cloudFiles.schemaLocation for schema inference and evolution

Referência: https://docs.databricks.com/aws/en/ingestion/cloud-object-storage/auto-loader/

Treinar esta prova no Ranvier →

02 — Camada de Mielina · Discussão Canônica

Onde a prova tenta te enganar — e como quem passou resolveu.

0 Aprovados

contribuíram nesta questão

Matriz de Dissecção de Alternativas Clique numa alternativa para filtrar ou inaugurar a dissecção.
✦ Síntese Consolidada (Wiki) rev. #1 (baseline) · CC BY-SA 4.0
Inaugurar síntese desta questão →

Ainda não há síntese comunitária consolidada para esta questão. Abaixo está o ponto de partida oficial verificável — se você passou na prova, inaugure a dissecção das alternativas.

Gabarito Oficial (C): Use spark.readStream.format("cloudFiles") with cloudFiles.format and a durable cloudFiles.schemaLocation for schema inference and evolution

Ranvier · DBDEA

Contribuir com a Questão

Sua contribuição constrói sua Bainha Orbital

Contribuições dos pares

Nenhuma contribuição pública ainda. Seja o primeiro aprovado a explicar por que as alternativas incorretas enganam — sua contribuição constrói sua Bainha Orbital.