== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#912386, add#912387, remove#912388, metaData#912389, protocol#912390, cdc#912391, checkpointMetadata#912392, sidecar#912393, domainMetadata#912394, commitInfo#912395]
Arguments: [txn#912386, add#912387, remove#912388, metaData#912389, protocol#912390, cdc#912391, checkpointMetadata#912392, sidecar#912393, domainMetadata#912394, commitInfo#912395], MapPartitionsRDD[42733] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#912386, add#912387, remove#912388, metaData#912389, protocol#912390, cdc#912391, checkpointMetadata#912392, sidecar#912393, domainMetadata#912394, commitInfo#912395]
Condition : isnotnull(add#912387)
(3) Project [codegen id : 1]
Output [11]: [add#912387.path AS path#912439, add#912387.partitionValues AS partitionValues#912440, add#912387.size AS size#912441L, add#912387.modificationTime AS modificationTime#912442L, add#912387.dataChange AS dataChange#912443, null AS stats#912450, add#912387.tags AS tags#912445, add#912387.deletionVector AS deletionVector#912446, add#912387.baseRowId AS baseRowId#912447L, add#912387.defaultRowCommitVersion AS defaultRowCommitVersion#912448L, add#912387.clusteringProvider AS clusteringProvider#912449]
Input [10]: [txn#912386, add#912387, remove#912388, metaData#912389, protocol#912390, cdc#912391, checkpointMetadata#912392, sidecar#912393, domainMetadata#912394, commitInfo#912395]