== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#824750, add#824751, remove#824752, metaData#824753, protocol#824754, cdc#824755, checkpointMetadata#824756, sidecar#824757, domainMetadata#824758, commitInfo#824759]
Arguments: [txn#824750, add#824751, remove#824752, metaData#824753, protocol#824754, cdc#824755, checkpointMetadata#824756, sidecar#824757, domainMetadata#824758, commitInfo#824759], MapPartitionsRDD[38650] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#824750, add#824751, remove#824752, metaData#824753, protocol#824754, cdc#824755, checkpointMetadata#824756, sidecar#824757, domainMetadata#824758, commitInfo#824759]
Condition : isnotnull(add#824751)
(3) Project [codegen id : 1]
Output [11]: [add#824751.path AS path#824803, add#824751.partitionValues AS partitionValues#824804, add#824751.size AS size#824805L, add#824751.modificationTime AS modificationTime#824806L, add#824751.dataChange AS dataChange#824807, add#824751.stats AS stats#824808, add#824751.tags AS tags#824809, add#824751.deletionVector AS deletionVector#824810, add#824751.baseRowId AS baseRowId#824811L, add#824751.defaultRowCommitVersion AS defaultRowCommitVersion#824812L, add#824751.clusteringProvider AS clusteringProvider#824813]
Input [10]: [txn#824750, add#824751, remove#824752, metaData#824753, protocol#824754, cdc#824755, checkpointMetadata#824756, sidecar#824757, domainMetadata#824758, commitInfo#824759]