Certified Data Engineer Associate 2026

1. A data engineer has a DataFrame, salesDf, wilh a column named amount and wants to

  1. Permanently rename this column to total_amount for all future operations on salesDf
  2. In a separate query, temporarily show the column as gross_amount in the result, without changing the underlying schema

Which set of code fragments meets the requirements?

Operation 1: salesDf = salesDf.withColumnRenamed(“amount”, “total_amount”)
Operation 2: salesDf.select(col(“*”), col(“amount”).alias(“gross_amount”))

2. A data engineer builds a Lakeflow Job that ingests JSON logs from cloud storage. New files arrive at unpredictable times, and the team wants to automatically run the job as soon as new files land so the data is processed immediately. What trigger configuration should the data engineer use for this job?

File arrival trigger