pyspark - 使用更改日志装饰器时如何写回输出数据帧？

Question

我正在尝试使用 changelog python transform 装饰器处理包含给定输入数据集的所有记录的完整更改历史的 changelog 数据集。我只想知道如何在对输入数据集执行一些转换后使用 write_dataframe() 函数写回变更日志数据集。