我正在寻找一种在 python 中写回增量表而不使用 pyspark 的方法。我知道有一个名为 deltalake/ delta-lake-reader 的库,可用于读取 delta 表并将其转换为 pandas 数据帧。
目标是写回打开的增量表
输入代码如下所示:
from deltalake import DeltaTable
dt = DeltaTable('path/file')
df = dt.to_pandas()
Run Code Online (Sandbox Code Playgroud)
那么有没有办法让这样的东西从 pandas 数据帧写回增量表:
df = pandadf.to_delta()
DeltaTable.write(df, 'path/file')
Run Code Online (Sandbox Code Playgroud)
谢谢您的帮助!