== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#17237, add#17238, remove#17239, metaData#17240, protocol#17241, cdc#17242, checkpointMetadata#17243, sidecar#17244, domainMetadata#17245, commitInfo#17246]
Arguments: [txn#17237, add#17238, remove#17239, metaData#17240, protocol#17241, cdc#17242, checkpointMetadata#17243, sidecar#17244, domainMetadata#17245, commitInfo#17246], MapPartitionsRDD[1704] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#17237, add#17238, remove#17239, metaData#17240, protocol#17241, cdc#17242, checkpointMetadata#17243, sidecar#17244, domainMetadata#17245, commitInfo#17246]
Condition : isnotnull(add#17238)
(3) Project [codegen id : 1]
Output [11]: [add#17238.path AS path#17290, add#17238.partitionValues AS partitionValues#17291, add#17238.size AS size#17292L, add#17238.modificationTime AS modificationTime#17293L, add#17238.dataChange AS dataChange#17294, add#17238.stats AS stats#17295, add#17238.tags AS tags#17296, add#17238.deletionVector AS deletionVector#17297, add#17238.baseRowId AS baseRowId#17298L, add#17238.defaultRowCommitVersion AS defaultRowCommitVersion#17299L, add#17238.clusteringProvider AS clusteringProvider#17300]
Input [10]: [txn#17237, add#17238, remove#17239, metaData#17240, protocol#17241, cdc#17242, checkpointMetadata#17243, sidecar#17244, domainMetadata#17245, commitInfo#17246]