User15725630784
Databricks Employee
Databricks Employee

the equivalent code in Apache Spark is:

  1. XBCUD_Y_TMP1_DF = (XBCUD_DF
  2. .filter(col("act_ind") == "Y")
  3. .select(col("cust_hash_key"),
  4. concat(col("brd_abbr_cd"),col("ctry_cd")).alias("brdCtry"),
  5. col("updt_dt_hash_key"))
  6. )