== 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#59174, add#52034.partitionValues AS partitionValues#59175, add#52034.size AS size#59176L, add#52034.modificationTime AS modificationTime#59177L, add#52034.dataChange AS dataChange#59178, null AS stats#59185, add#52034.tags AS tags#59180, add#52034.deletionVector AS deletionVector#59181, add#52034.baseRowId AS baseRowId#59182L, add#52034.defaultRowCommitVersion AS defaultRowCommitVersion#59183L, add#52034.clusteringProvider AS clusteringProvider#59184]
Input [10]: [txn#52033, add#52034, remove#52035, metaData#52036, protocol#52037, cdc#52038, checkpointMetadata#52039, sidecar#52040, domainMetadata#52041, commitInfo#52042]