== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#1110376, add#1110377, remove#1110378, metaData#1110379, protocol#1110380, cdc#1110381, checkpointMetadata#1110382, sidecar#1110383, domainMetadata#1110384, commitInfo#1110385]
Arguments: [txn#1110376, add#1110377, remove#1110378, metaData#1110379, protocol#1110380, cdc#1110381, checkpointMetadata#1110382, sidecar#1110383, domainMetadata#1110384, commitInfo#1110385], MapPartitionsRDD[55278] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#1110376, add#1110377, remove#1110378, metaData#1110379, protocol#1110380, cdc#1110381, checkpointMetadata#1110382, sidecar#1110383, domainMetadata#1110384, commitInfo#1110385]
Condition : isnotnull(add#1110377)
(3) Project [codegen id : 1]
Output [11]: [add#1110377.path AS path#1110429, add#1110377.partitionValues AS partitionValues#1110430, add#1110377.size AS size#1110431L, add#1110377.modificationTime AS modificationTime#1110432L, add#1110377.dataChange AS dataChange#1110433, add#1110377.stats AS stats#1110434, add#1110377.tags AS tags#1110435, add#1110377.deletionVector AS deletionVector#1110436, add#1110377.baseRowId AS baseRowId#1110437L, add#1110377.defaultRowCommitVersion AS defaultRowCommitVersion#1110438L, add#1110377.clusteringProvider AS clusteringProvider#1110439]
Input [10]: [txn#1110376, add#1110377, remove#1110378, metaData#1110379, protocol#1110380, cdc#1110381, checkpointMetadata#1110382, sidecar#1110383, domainMetadata#1110384, commitInfo#1110385]