磚

我沒有試過,但我懷疑它會失敗插入相同的消息,因為加州大學。dl_id是一些空行和“whenNotMatchedInsertAll”將試圖插入dl_id字段的值,而不是生成一個(如果它已被用戶提供…

“電子商務”——永遠。“加州大學”——不是。因為“加州”可能包含需要附加的新數據。

我用11.2運行時。標識列創建為:dl_id BIGINT NOT NULL總是像IDENTITYand pyspark生成的代碼是一個插入:t.alias (ec) .merge (df.alias(加州大學),“電子商務。dl_id = uc.dl_id ") \ .whenMatchedUpdateAll () \ .whenN…