CDP-3002 Exam Question 111

In Apache Airflow, which strategy allows for the dynamic generation of tasks within a DAG based on external data sources, such as a list of database tables?
  • CDP-3002 Exam Question 112

    You have an Airflow DAG that includes tasks for data extraction, transformation, and loading. You notice that the transformation tasks are computationally intensive and are causing delays in the DAG's execution. To optimize performance, you decide to offload these tasks to a cloud-based service that can scale dynamically. Which approach ensures minimal changes to the DAG structure while integrating this optimization?
  • CDP-3002 Exam Question 113

    What advanced technique can be used in Hive to optimize queries on bucketed tables by skipping unnecessary data?
  • CDP-3002 Exam Question 114

    When creating a partitioned table in Hive, what does the clause PARTITIONED BY specify?
  • CDP-3002 Exam Question 115

    How does Apache NiFi support schema inference during data flow management?