最新的Databricks Certified Associate Developer for Apache Spark 3.5 - Python - Associate-Developer-Apache-Spark-3.5免費考試真題
The following code fragment results in an error:
@F.udf(T.IntegerType())
def simple_udf(t: str) -> str:
return answer * 3.14159
Which code fragment should be used instead?
@F.udf(T.IntegerType())
def simple_udf(t: str) -> str:
return answer * 3.14159
Which code fragment should be used instead?
正確答案: C
說明：（僅 Fast2test 成員可見）
An engineer has two DataFrames: df1 (small) and df2 (large). A broadcast join is used:
python
CopyEdit
from pyspark.sql.functions import broadcast
result = df2.join(broadcast(df1), on='id', how='inner')
What is the purpose of using broadcast() in this scenario?
Options:
python
CopyEdit
from pyspark.sql.functions import broadcast
result = df2.join(broadcast(df1), on='id', how='inner')
What is the purpose of using broadcast() in this scenario?
Options:
正確答案: C
說明：（僅 Fast2test 成員可見）
A data scientist at a financial services company is working with a Spark DataFrame containing transaction records. The DataFrame has millions of rows and includes columns for transaction_id, account_number, transaction_amount, and timestamp. Due to an issue with the source system, some transactions were accidentally recorded multiple times with identical information across all fields. The data scientist needs to remove rows with duplicates across all fields to ensure accurate financial reporting.
Which approach should the data scientist use to deduplicate the orders using PySpark?
Which approach should the data scientist use to deduplicate the orders using PySpark?
正確答案: B
說明：（僅 Fast2test 成員可見）
A data engineer is streaming data from Kafka and requires:
Minimal latency
Exactly-once processing guarantees
Which trigger mode should be used?
Minimal latency
Exactly-once processing guarantees
Which trigger mode should be used?
正確答案: C
說明：（僅 Fast2test 成員可見）
What is the risk associated with this operation when converting a large Pandas API on Spark DataFrame back to a Pandas DataFrame?
正確答案: B
說明：（僅 Fast2test 成員可見）
Given the following code snippet in my_spark_app.py:
What is the role of the driver node?
What is the role of the driver node?
正確答案: B
說明：（僅 Fast2test 成員可見）
Which configuration can be enabled to optimize the conversion between Pandas and PySpark DataFrames using Apache Arrow?
正確答案: B
說明：（僅 Fast2test 成員可見）
A DataFrame df has columns name, age, and salary. The developer needs to sort the DataFrame by age in ascending order and salary in descending order.
Which code snippet meets the requirement of the developer?
Which code snippet meets the requirement of the developer?
正確答案: D
說明：（僅 Fast2test 成員可見）