Cloudera CDP-3002 試験概要:

Cloudera CDP-3002 試験シラバストピック:

Cloudera CDP Data Engineer - Certification 認定 CDP-3002 試験問題：

1. Your Airflow DAG involves tasks that require access to confidential data like passwords or API keys. How can you securely manage and access these credentials within the DAG?

A) Store the credentials directly within the DAG code, assuming limited access to the codebase.
B) Utilize environment variables to store the credentials and access them within the tasks.
C) Implement a custom secret management solution outside of Airflow.
D) All of the above

2. You're writing a Spark application that processes streaming data in real-time. How can you create DataFrames from streaming data sources?

A) Utilize Spark SQL's streaming capabilities with the FROM clause
B) Leverage Spark Streaming's functions like createDataFrame with appropriate parameters
C) All of the above
D) Use the same methods as for batch processing, reading data from a file

3. When using Apache Airflow to schedule quality checks, which strategy helps ensure that checks are only run on the most recent data partition?
A Use the LatestOnlyOperator to skip tasks that are not the latest in a series of executions.

A) Apply the depends_on_past=True parameter to the quality check task.
B) Implement a custom PythonOperator that queries the database for the latest partition.
C) Utilize the execution_date in your SQL query to target the latest partition.

4. What is the purpose of the Airflow XCom feature?

A) To monitor and log the execution of DAGs
B) To schedule DAG runs at specific intervals
C) To execute tasks on remote machines
D) To enable communication between tasks in a DAG

5. In a PySpark application running on Kubernetes, you want to enable dynamic allocation of Executors. Which configuration setting is essential to turn on this feature?

A) 'spark.kubernetes.executor.dynamicAllocation'
B) 'spark.kubernetes.dynamicAllocation.enabled'
C) 'spark.dynamicAllocation.enabled'
D) 'spark.executor.instances'

質問と回答：