== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#38464, add#38465, remove#38466, metaData#38467, protocol#38468, cdc#38469, checkpointMetadata#38470, sidecar#38471, domainMetadata#38472, commitInfo#38473]
Arguments: [txn#38464, add#38465, remove#38466, metaData#38467, protocol#38468, cdc#38469, checkpointMetadata#38470, sidecar#38471, domainMetadata#38472, commitInfo#38473], MapPartitionsRDD[1906] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#38464, add#38465, remove#38466, metaData#38467, protocol#38468, cdc#38469, checkpointMetadata#38470, sidecar#38471, domainMetadata#38472, commitInfo#38473]
Condition : isnotnull(add#38465)
(3) Project [codegen id : 1]
Output [11]: [add#38465.path AS path#38517, add#38465.partitionValues AS partitionValues#38518, add#38465.size AS size#38519L, add#38465.modificationTime AS modificationTime#38520L, add#38465.dataChange AS dataChange#38521, null AS stats#38528, add#38465.tags AS tags#38523, add#38465.deletionVector AS deletionVector#38524, add#38465.baseRowId AS baseRowId#38525L, add#38465.defaultRowCommitVersion AS defaultRowCommitVersion#38526L, add#38465.clusteringProvider AS clusteringProvider#38527]
Input [10]: [txn#38464, add#38465, remove#38466, metaData#38467, protocol#38468, cdc#38469, checkpointMetadata#38470, sidecar#38471, domainMetadata#38472, commitInfo#38473]