== 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#52224, add#52034.partitionValues AS partitionValues#52225, add#52034.size AS size#52226L, add#52034.modificationTime AS modificationTime#52227L, add#52034.dataChange AS dataChange#52228, null AS stats#52235, add#52034.tags AS tags#52230, add#52034.deletionVector AS deletionVector#52231, add#52034.baseRowId AS baseRowId#52232L, add#52034.defaultRowCommitVersion AS defaultRowCommitVersion#52233L, add#52034.clusteringProvider AS clusteringProvider#52234]
Input [10]: [txn#52033, add#52034, remove#52035, metaData#52036, protocol#52037, cdc#52038, checkpointMetadata#52039, sidecar#52040, domainMetadata#52041, commitInfo#52042]