File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change 88 ;; derived from the CSV's METADATA$ROW_ID column).
99 (csv_data
1010 (csv_locator
11- (paths "s3://bucket/cdc/edges_batch_001 .csv"))
11+ (paths "s3://bucket/edges .csv"))
1212 (csv_config {})
1313 ;; Insert and delete deltas must target DISTINCT relations (like the legacy
14- ;; columnar loader): a row's METADATA$ACTION routes it to :edge_ins or :edge_del .
14+ ;; columnar loader): a row's METADATA$ACTION routes it to :weight_ins or :weight_del .
1515 (relations
1616 (keys
1717 (column "METADATA$KEY" UINT128))
1818 (inserts
19- (relation :edge_ins
19+ (relation :weight_ins
2020 (column "weight" FLOAT)))
2121 (deletes
22- (relation :edge_del
22+ (relation :weight_del
2323 (column "weight" FLOAT))))
2424 (asof "2025-06-01T00:00:00Z")))))
2525
2626 (reads
27- (output :edge_ins :edge_ins )
28- (output :edge_del :edge_del ))))
27+ (output :weight_ins :weight_ins )
28+ (output :weight_del :weight_del ))))
Original file line number Diff line number Diff line change 66 (fragment
77 :f1
88 (csv_data
9- (csv_locator (paths "s3://bucket/cdc/edges_batch_001 .csv"))
9+ (csv_locator (paths "s3://bucket/edges .csv"))
1010 (csv_config
1111 {
1212 :csv_compression "auto"
1919 :csv_skip 0})
2020 (relations
2121 (keys (column "METADATA$KEY" UINT128))
22- (inserts (relation :edge_ins (column "weight" FLOAT))) (deletes
23- (relation :edge_del (column "weight" FLOAT))))
22+ (inserts (relation :weight_ins (column "weight" FLOAT))) (deletes
23+ (relation :weight_del (column "weight" FLOAT))))
2424 (asof "2025-06-01T00:00:00Z")))))
25- (reads (output :edge_ins :edge_ins ) (output :edge_del :edge_del ))))
25+ (reads (output :weight_ins :weight_ins ) (output :weight_del :weight_del ))))
Original file line number Diff line number Diff line change 66 (fragment
77 :f1
88 (csv_data
9- (csv_locator (paths "s3://bucket/cdc/edges_batch_001 .csv"))
9+ (csv_locator (paths "s3://bucket/edges .csv"))
1010 (csv_config
1111 {
1212 :csv_compression "auto"
1919 :csv_skip 0})
2020 (relations
2121 (keys (column "METADATA$KEY" UINT128))
22- (inserts
23- (relation 0x6c9225cf3609ca4d26168fd6652e0d03 (column "weight" FLOAT))) (deletes
24- (relation 0x5ef875f96a25ff5f076bea0e815c6ce0 (column "weight" FLOAT))))
22+ (inserts (relation 0x678037975b01b6389c78bc1cc79abde (column "weight" FLOAT))) (deletes
23+ (relation 0xb214f85adaa2e403bed30d3721f4363 (column "weight" FLOAT))))
2524 (asof "2025-06-01T00:00:00Z")))))
2625 (reads
27- (output :edge_ins 0x6c9225cf3609ca4d26168fd6652e0d03 )
28- (output :edge_del 0x5ef875f96a25ff5f076bea0e815c6ce0 ))))
26+ (output :weight_ins 0x678037975b01b6389c78bc1cc79abde )
27+ (output :weight_del 0xb214f85adaa2e403bed30d3721f4363 ))))
2928
3029;; Debug information
3130;; -----------------------
3231;; Original names
33- ;; ID `0x5ef875f96a25ff5f076bea0e815c6ce0 ` -> `edge_del `
34- ;; ID `0x6c9225cf3609ca4d26168fd6652e0d03 ` -> `edge_ins `
32+ ;; ID `0xb214f85adaa2e403bed30d3721f4363 ` -> `weight_del `
33+ ;; ID `0x678037975b01b6389c78bc1cc79abde ` -> `weight_ins `
You can’t perform that action at this time.
0 commit comments