磚

df_source_records.filter (F.col (“_change_type”)。isin(“刪除”,“插入”,“update_postimage”)) .withColumn (“ROW_NUMBER F.row_number () .over(窗口)).filter (“ROW_NUMBE……