Дельта-обновление Databricks

Как мы можем обновить несколько записей в таблице из другой таблицы, используя дельту блоков данных.

Я хочу добиться чего-то вроде:

update ExistingTable set
IsQualified = updates.IsQualified From updates  where ExistingTable.key= updates.key

Сбой с ошибкой: несоответствующий ввод "От" ожидает


delta-lake databricks apache-spark-sql
person Psingla    schedule 04.09.2018    source источник

Ответы (2)


arrow_upward
0
arrow_downward

  1. Можно использовать Merge для небольшого набора данных, потому что он имеет текущий предел 10k

Более того, подзапросы не поддерживаются в заявлении об обновлении, но находятся в невыполнении работы группы блоков данных.

person Psingla    schedule 04.09.2018

arrow_upward
0
arrow_downward

Теперь вы можете сделать то же самое, используя 5.0 Beta или Official, используя MERGE INTO, ограничение в 10 КБ фиксируется после 4.0. Если понадобится, я тоже помогу с UPSERTs.

person Harsha TJ    schedule 28.11.2018