将零售数据以流方式写入 Delta Lake
新的订单文件每天都会落入 Global Retail Analytics 团队的 volume 中。
与其每天早上全部重载,您将构建一条流式管道,自动拾取新的 CSV 文件、写入 Delta Lake,并使用检查点在重启后平稳恢复。
本练习是课程的一部分
新的订单文件每天都会落入 Global Retail Analytics 团队的 volume 中。
与其每天早上全部重载,您将构建一条流式管道,自动拾取新的 CSV 文件、写入 Delta Lake,并使用检查点在重启后平稳恢复。
本练习是课程的一部分