== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#142082, add#142083, remove#142084, metaData#142085, protocol#142086, cdc#142087, checkpointMetadata#142088, sidecar#142089, domainMetadata#142090, commitInfo#142091]
Arguments: [txn#142082, add#142083, remove#142084, metaData#142085, protocol#142086, cdc#142087, checkpointMetadata#142088, sidecar#142089, domainMetadata#142090, commitInfo#142091], MapPartitionsRDD[8275] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#142082, add#142083, remove#142084, metaData#142085, protocol#142086, cdc#142087, checkpointMetadata#142088, sidecar#142089, domainMetadata#142090, commitInfo#142091]
Condition : isnotnull(add#142083)
(3) Project [codegen id : 1]
Output [11]: [add#142083.path AS path#142135, add#142083.partitionValues AS partitionValues#142136, add#142083.size AS size#142137L, add#142083.modificationTime AS modificationTime#142138L, add#142083.dataChange AS dataChange#142139, add#142083.stats AS stats#142140, add#142083.tags AS tags#142141, add#142083.deletionVector AS deletionVector#142142, add#142083.baseRowId AS baseRowId#142143L, add#142083.defaultRowCommitVersion AS defaultRowCommitVersion#142144L, add#142083.clusteringProvider AS clusteringProvider#142145]
Input [10]: [txn#142082, add#142083, remove#142084, metaData#142085, protocol#142086, cdc#142087, checkpointMetadata#142088, sidecar#142089, domainMetadata#142090, commitInfo#142091]