如何一次从delta lake表查询所有版本,以跟踪对特定id所做的更改

wmomyfyw  于 2021-05-27  发布在  Spark
关注(0)|答案(0)|浏览(277)

我有一张员工桌 salary 在所有的 employee 他用三角洲湖管理。
我可以使用delta-lake支持的时间旅行特性,基于版本或时间戳来查询表。

SELECT *
FROM DELTA.`EMPLOYEE`
VERSION AS OF 3

但是我想知道在delta表的所有版本中对员工所做的所有更改的历史记录。像这样的

SELECT *
, timestamp -- From delta table
, version -- From delta table
FROM DELTA.`EMPLOYEE`
WHERE EMPLOYEE = 'George'
WITHIN ALL VERSIONS --Never exists but just for understanding

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题