== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#922838, add#922839, remove#922840, metaData#922841, protocol#922842, cdc#922843, checkpointMetadata#922844, sidecar#922845, domainMetadata#922846, commitInfo#922847]
Arguments: [txn#922838, add#922839, remove#922840, metaData#922841, protocol#922842, cdc#922843, checkpointMetadata#922844, sidecar#922845, domainMetadata#922846, commitInfo#922847], MapPartitionsRDD[43296] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#922838, add#922839, remove#922840, metaData#922841, protocol#922842, cdc#922843, checkpointMetadata#922844, sidecar#922845, domainMetadata#922846, commitInfo#922847]
Condition : isnotnull(add#922839)
(3) Project [codegen id : 1]
Output [11]: [add#922839.path AS path#922891, add#922839.partitionValues AS partitionValues#922892, add#922839.size AS size#922893L, add#922839.modificationTime AS modificationTime#922894L, add#922839.dataChange AS dataChange#922895, add#922839.stats AS stats#922896, add#922839.tags AS tags#922897, add#922839.deletionVector AS deletionVector#922898, add#922839.baseRowId AS baseRowId#922899L, add#922839.defaultRowCommitVersion AS defaultRowCommitVersion#922900L, add#922839.clusteringProvider AS clusteringProvider#922901]
Input [10]: [txn#922838, add#922839, remove#922840, metaData#922841, protocol#922842, cdc#922843, checkpointMetadata#922844, sidecar#922845, domainMetadata#922846, commitInfo#922847]