== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD Delta Table State #2 - hdlfs://9b46f9d5-066e-49af-bc5c-7af37534ca4d.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-product-productplant/_delta_log (1)
(1) Scan ExistingRDD Delta Table State #2 - hdlfs://9b46f9d5-066e-49af-bc5c-7af37534ca4d.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-product-productplant/_delta_log [codegen id : 1]
Output [10]: [txn#52033, add#52034, remove#52035, metaData#52036, protocol#52037, cdc#52038, checkpointMetadata#52039, sidecar#52040, domainMetadata#52041, commitInfo#52042]
Arguments: [txn#52033, add#52034, remove#52035, metaData#52036, protocol#52037, cdc#52038, checkpointMetadata#52039, sidecar#52040, domainMetadata#52041, commitInfo#52042], Delta Table State #2 - hdlfs://9b46f9d5-066e-49af-bc5c-7af37534ca4d.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-product-productplant/_delta_log MapPartitionsRDD[2693] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#52033, add#52034, remove#52035, metaData#52036, protocol#52037, cdc#52038, checkpointMetadata#52039, sidecar#52040, domainMetadata#52041, commitInfo#52042]
Condition : isnotnull(add#52034)
(3) Project [codegen id : 1]
Output [11]: [add#52034.path AS path#63693, add#52034.partitionValues AS partitionValues#63694, add#52034.size AS size#63695L, add#52034.modificationTime AS modificationTime#63696L, add#52034.dataChange AS dataChange#63697, null AS stats#63704, add#52034.tags AS tags#63699, add#52034.deletionVector AS deletionVector#63700, add#52034.baseRowId AS baseRowId#63701L, add#52034.defaultRowCommitVersion AS defaultRowCommitVersion#63702L, add#52034.clusteringProvider AS clusteringProvider#63703]
Input [10]: [txn#52033, add#52034, remove#52035, metaData#52036, protocol#52037, cdc#52038, checkpointMetadata#52039, sidecar#52040, domainMetadata#52041, commitInfo#52042]