== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#102, add#103, remove#104, metaData#105, protocol#106, cdc#107, checkpointMetadata#108, sidecar#109, domainMetadata#110, commitInfo#111]
Arguments: [txn#102, add#103, remove#104, metaData#105, protocol#106, cdc#107, checkpointMetadata#108, sidecar#109, domainMetadata#110, commitInfo#111], MapPartitionsRDD[4] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#102, add#103, remove#104, metaData#105, protocol#106, cdc#107, checkpointMetadata#108, sidecar#109, domainMetadata#110, commitInfo#111]
Condition : isnotnull(add#103)
(3) Project [codegen id : 1]
Output [11]: [add#103.path AS path#176, add#103.partitionValues AS partitionValues#177, add#103.size AS size#178L, add#103.modificationTime AS modificationTime#179L, add#103.dataChange AS dataChange#180, null AS stats#187, add#103.tags AS tags#182, add#103.deletionVector AS deletionVector#183, add#103.baseRowId AS baseRowId#184L, add#103.defaultRowCommitVersion AS defaultRowCommitVersion#185L, add#103.clusteringProvider AS clusteringProvider#186]
Input [10]: [txn#102, add#103, remove#104, metaData#105, protocol#106, cdc#107, checkpointMetadata#108, sidecar#109, domainMetadata#110, commitInfo#111]