您可以使用該功能表API來更新你的表在現有“覆蓋”:
fs。= ' recommender_system write_table(名稱。customer_features’, df = customer_features_df模式= '覆蓋”)
如果不工作為你的用例,每個特性存儲表代表了一個傳統的差值表。所以,你可以做下一個:
df.write。選項(“mergeSchema”,“真正的”).format(“δ”).mode(模式=“覆蓋”).saveAsTable (delta_table_name)
最後,您可以注冊一個現有的三角洲表特性表:
fs。register_table (delta_table = '推薦。customer_features’, primary_keys = ' customer_id”,描述= '客戶特性”)
您可以使用該功能表API來更新你的表在現有“覆蓋”:
fs。= ' recommender_system write_table(名稱。customer_features’, df = customer_features_df模式= '覆蓋”)
如果不工作為你的用例,每個特性存儲表代表了一個傳統的差值表。所以,你可以做下一個:
df.write。選項(“mergeSchema”,“真正的”).format(“δ”).mode(模式=“覆蓋”).saveAsTable (delta_table_name)
最後,您可以注冊一個現有的三角洲表特性表:
fs。register_table (delta_table = '推薦。customer_features’, primary_keys = ' customer_id”,描述= '客戶特性”)
嗨@Artem Sheiko列已經改變的模式,模式=“覆蓋”不工作。當我遇到這個問題與三角洲表可以通過DataFrameWriter.saveAsTable overwriteSchema = True參數。
這將是偉大的如果fs。write_table args mergeSchema & overwriteSchema