Using column merge while you have spaces in the attribute names

 



def write_to_bronze_table(df,table_name):
    df.write.format('delta').mode('overwrite')
                            .option('overwriteSchema','true')
                            .option('delta.columnMapping.mode','name')
                            .saveAsTable(f'superstore_catalog.bronze_schema.{table_name}')
write_to_bronze_table(df_bronze,'bronze_table')












Comments