== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#1110278, add#1110279, remove#1110280, metaData#1110281, protocol#1110282, cdc#1110283, checkpointMetadata#1110284, sidecar#1110285, domainMetadata#1110286, commitInfo#1110287]
Arguments: [txn#1110278, add#1110279, remove#1110280, metaData#1110281, protocol#1110282, cdc#1110283, checkpointMetadata#1110284, sidecar#1110285, domainMetadata#1110286, commitInfo#1110287], MapPartitionsRDD[55274] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#1110278, add#1110279, remove#1110280, metaData#1110281, protocol#1110282, cdc#1110283, checkpointMetadata#1110284, sidecar#1110285, domainMetadata#1110286, commitInfo#1110287]
Condition : isnotnull(add#1110279)
(3) Project [codegen id : 1]
Output [11]: [add#1110279.path AS path#1110331, add#1110279.partitionValues AS partitionValues#1110332, add#1110279.size AS size#1110333L, add#1110279.modificationTime AS modificationTime#1110334L, add#1110279.dataChange AS dataChange#1110335, null AS stats#1110342, add#1110279.tags AS tags#1110337, add#1110279.deletionVector AS deletionVector#1110338, add#1110279.baseRowId AS baseRowId#1110339L, add#1110279.defaultRowCommitVersion AS defaultRowCommitVersion#1110340L, add#1110279.clusteringProvider AS clusteringProvider#1110341]
Input [10]: [txn#1110278, add#1110279, remove#1110280, metaData#1110281, protocol#1110282, cdc#1110283, checkpointMetadata#1110284, sidecar#1110285, domainMetadata#1110286, commitInfo#1110287]