== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#19363, add#19364, remove#19365, metaData#19366, protocol#19367, cdc#19368, checkpointMetadata#19369, sidecar#19370, domainMetadata#19371, commitInfo#19372]
Arguments: [txn#19363, add#19364, remove#19365, metaData#19366, protocol#19367, cdc#19368, checkpointMetadata#19369, sidecar#19370, domainMetadata#19371, commitInfo#19372], MapPartitionsRDD[1916] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#19363, add#19364, remove#19365, metaData#19366, protocol#19367, cdc#19368, checkpointMetadata#19369, sidecar#19370, domainMetadata#19371, commitInfo#19372]
Condition : isnotnull(add#19364)
(3) Project [codegen id : 1]
Output [11]: [add#19364.path AS path#19416, add#19364.partitionValues AS partitionValues#19417, add#19364.size AS size#19418L, add#19364.modificationTime AS modificationTime#19419L, add#19364.dataChange AS dataChange#19420, add#19364.stats AS stats#19421, add#19364.tags AS tags#19422, add#19364.deletionVector AS deletionVector#19423, add#19364.baseRowId AS baseRowId#19424L, add#19364.defaultRowCommitVersion AS defaultRowCommitVersion#19425L, add#19364.clusteringProvider AS clusteringProvider#19426]
Input [10]: [txn#19363, add#19364, remove#19365, metaData#19366, protocol#19367, cdc#19368, checkpointMetadata#19369, sidecar#19370, domainMetadata#19371, commitInfo#19372]