我很想知道在每日增量合并逻辑中插入了多少条记录,更新了多少条记录。我的示例数据帧: df_latest = spark.createDataFrame( ('Java', "20000"), # create your data here, be consistentlanguage", "users_count"] # add your column names here
) 当我执行下面的增量合并逻辑时,我将需要多一个名为flag wit
是否有一种简单的方法可以选择以前的delta表版本作为当前/工作版本?
我们可以指定一个版本为“当前/最新”版本,而不是由overwrite/truncate创建另一个版本吗?这个操作更像undo,它完全删除了一些步骤,并使数据进入前一个阶段。然后,在执行select * from MYTABLE时,这个MYTABLE可以指向恢复的版本。