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
Post a Comment