== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#1244, add#1245, remove#1246, metaData#1247, protocol#1248, cdc#1249, checkpointMetadata#1250, sidecar#1251, domainMetadata#1252, commitInfo#1253]
Arguments: [txn#1244, add#1245, remove#1246, metaData#1247, protocol#1248, cdc#1249, checkpointMetadata#1250, sidecar#1251, domainMetadata#1252, commitInfo#1253], MapPartitionsRDD[120] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#1244, add#1245, remove#1246, metaData#1247, protocol#1248, cdc#1249, checkpointMetadata#1250, sidecar#1251, domainMetadata#1252, commitInfo#1253]
Condition : isnotnull(add#1245)
(3) Project [codegen id : 1]
Output [11]: [add#1245.path AS path#1297, add#1245.partitionValues AS partitionValues#1298, add#1245.size AS size#1299L, add#1245.modificationTime AS modificationTime#1300L, add#1245.dataChange AS dataChange#1301, null AS stats#1308, add#1245.tags AS tags#1303, add#1245.deletionVector AS deletionVector#1304, add#1245.baseRowId AS baseRowId#1305L, add#1245.defaultRowCommitVersion AS defaultRowCommitVersion#1306L, add#1245.clusteringProvider AS clusteringProvider#1307]
Input [10]: [txn#1244, add#1245, remove#1246, metaData#1247, protocol#1248, cdc#1249, checkpointMetadata#1250, sidecar#1251, domainMetadata#1252, commitInfo#1253]