== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#921667, add#921668, remove#921669, metaData#921670, protocol#921671, cdc#921672, checkpointMetadata#921673, sidecar#921674, domainMetadata#921675, commitInfo#921676]
Arguments: [txn#921667, add#921668, remove#921669, metaData#921670, protocol#921671, cdc#921672, checkpointMetadata#921673, sidecar#921674, domainMetadata#921675, commitInfo#921676], MapPartitionsRDD[43158] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#921667, add#921668, remove#921669, metaData#921670, protocol#921671, cdc#921672, checkpointMetadata#921673, sidecar#921674, domainMetadata#921675, commitInfo#921676]
Condition : isnotnull(add#921668)
(3) Project [codegen id : 1]
Output [11]: [add#921668.path AS path#921720, add#921668.partitionValues AS partitionValues#921721, add#921668.size AS size#921722L, add#921668.modificationTime AS modificationTime#921723L, add#921668.dataChange AS dataChange#921724, add#921668.stats AS stats#921725, add#921668.tags AS tags#921726, add#921668.deletionVector AS deletionVector#921727, add#921668.baseRowId AS baseRowId#921728L, add#921668.defaultRowCommitVersion AS defaultRowCommitVersion#921729L, add#921668.clusteringProvider AS clusteringProvider#921730]
Input [10]: [txn#921667, add#921668, remove#921669, metaData#921670, protocol#921671, cdc#921672, checkpointMetadata#921673, sidecar#921674, domainMetadata#921675, commitInfo#921676]