Объединение нескольких условий в DeltaTable с помощью Pyspark ⇐ Python

[Anonymous]

Я создал процесс с использованием таблицы дельты для обновления данных с помощью ключей ID_CLIENT и ID_PRODUCT, но получаю сообщение об ошибке:

Объединить при совпадении нескольких исходных строк

Можно ли выполнить объединение с несколькими условиями?
tabela_spec.alias("current") \
.merge(dfrn.alias("update"), "current.id_client = update.id_client AND current.id_product = update.id_product") \
.whenMatchedUpdateAll().whenNotMatchedInsertAll() \
.execute()


Подробнее здесь: https://stackoverflow.com/questions/704 ... ng-pyspark