Question 1

Which method is recommended to avoid schema inference overhead in Spark SQL queries?

Options :

A : Use spark.conf.set("spark.sql.schema", schema)

B : Rely on default schema inference

C : Use DataFrameReader.option("schema", schema) to specify a schema

D : Use spark.sql("SET schema = schema")

Answer: C

Question 2

What is the purpose of the retry parameter in an Apache Airflow DAG task?

Options :

A : To determine task dependencies

B : To control the number of retries after a failure

C : To manage task scheduling

D : To define the task-s execution time

Answer: B

Question 3

How can you monitor and troubleshoot data pipelines in Cloudera?

Options :

A : By checking application logs only

B : Using external monitoring tools

C : By reviewing data files manually

D : Using Cloudera Manager

Answer: D

Question 4

What is a key method for improving join performance in Cloudera's Hadoop ecosystem?

Options :

A : Use hash joins

B : Increase cluster size

C : Use nested loops

D : Increase network bandwidth

Answer: A

Question 5

What is the impact of using cost-based optimization in the Cloudera Optimization Framework?

Options :

A : It simplifies query syntax

B : It speeds up data transfer

C : It selects the most efficient execution plan based on cost estimates

D : It reduces storage requirements

Answer: C

Higher Test Marks with Free Online CDP-3002 Exam Practice