== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#740155, add#740156, remove#740157, metaData#740158, protocol#740159, cdc#740160, checkpointMetadata#740161, sidecar#740162, domainMetadata#740163, commitInfo#740164]
Arguments: [txn#740155, add#740156, remove#740157, metaData#740158, protocol#740159, cdc#740160, checkpointMetadata#740161, sidecar#740162, domainMetadata#740163, commitInfo#740164], MapPartitionsRDD[34821] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#740155, add#740156, remove#740157, metaData#740158, protocol#740159, cdc#740160, checkpointMetadata#740161, sidecar#740162, domainMetadata#740163, commitInfo#740164]
Condition : isnotnull(add#740156)
(3) Project [codegen id : 1]
Output [11]: [add#740156.path AS path#740208, add#740156.partitionValues AS partitionValues#740209, add#740156.size AS size#740210L, add#740156.modificationTime AS modificationTime#740211L, add#740156.dataChange AS dataChange#740212, add#740156.stats AS stats#740213, add#740156.tags AS tags#740214, add#740156.deletionVector AS deletionVector#740215, add#740156.baseRowId AS baseRowId#740216L, add#740156.defaultRowCommitVersion AS defaultRowCommitVersion#740217L, add#740156.clusteringProvider AS clusteringProvider#740218]
Input [10]: [txn#740155, add#740156, remove#740157, metaData#740158, protocol#740159, cdc#740160, checkpointMetadata#740161, sidecar#740162, domainMetadata#740163, commitInfo#740164]