我有一個簡單的DLT管道讀取從現有表,做一些轉換,節省了一個視圖,然後使用dlt.apply_changes()將視圖插入一個結果表。我的問題是:
@dlt。視圖(name = " cool_table) def transform_uncool_table():返回(火花。readStream .option (“ignoreChanges”、“true”) .table dlt (“uncool_table”))。create_streaming_live_table (name = " target_table table_properties ={“質量”:“黃金”})dlt。apply_changes(目標=“target_table”,源=“cool_table”鍵= [“pair_hash”], sequence_by =“last_seen”)