== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#832545, add#832546, remove#832547, metaData#832548, protocol#832549, cdc#832550, checkpointMetadata#832551, sidecar#832552, domainMetadata#832553, commitInfo#832554]
Arguments: [txn#832545, add#832546, remove#832547, metaData#832548, protocol#832549, cdc#832550, checkpointMetadata#832551, sidecar#832552, domainMetadata#832553, commitInfo#832554], MapPartitionsRDD[39022] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#832545, add#832546, remove#832547, metaData#832548, protocol#832549, cdc#832550, checkpointMetadata#832551, sidecar#832552, domainMetadata#832553, commitInfo#832554]
Condition : isnotnull(add#832546)
(3) Project [codegen id : 1]
Output [11]: [add#832546.path AS path#832598, add#832546.partitionValues AS partitionValues#832599, add#832546.size AS size#832600L, add#832546.modificationTime AS modificationTime#832601L, add#832546.dataChange AS dataChange#832602, add#832546.stats AS stats#832603, add#832546.tags AS tags#832604, add#832546.deletionVector AS deletionVector#832605, add#832546.baseRowId AS baseRowId#832606L, add#832546.defaultRowCommitVersion AS defaultRowCommitVersion#832607L, add#832546.clusteringProvider AS clusteringProvider#832608]
Input [10]: [txn#832545, add#832546, remove#832547, metaData#832548, protocol#832549, cdc#832550, checkpointMetadata#832551, sidecar#832552, domainMetadata#832553, commitInfo#832554]