當使用三角洲生活表,我怎麼設置一個表增量vs使用Python來完成?

[User16826992666]

使用SQL時,我可以使用創建生活表命令和命令來創建增量生活表設置運行類型我想要使用的表。但我似乎沒有相同的python語法。我如何設置這個表類型,而使用Python ?

[sajith_appukutt]

的文檔https://docs.m.eheci.com/data-engineering/delta-live-tables/delta-live-tables-user-guide.html混合…有一個例子

前兩個函數加載數據增量地最後一個完全裝載它

@dlt。視圖def incremental_bronze():返回(#由於這是一個流源,這個表是增量。spark.readStream.format .option (“cloudFiles (“cloudFiles”)。格式”、“json) .load (s3: / /路徑/ /生/數據”))@dlt。表def incremental_silver(): #因為我們讀青銅表流,這個銀表也是#增量更新。返回dlt.read_stream (“incremental_bronze”)。(…) @dlt。表def complete_gold(): #這個表將被重新計算完全閱讀整個銀表#時更新。返回dlt.read (incremental_silver) .groupBy (user_id) .count ()