== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#1292, add#1293, remove#1294, metaData#1295, protocol#1296, cdc#1297, checkpointMetadata#1298, sidecar#1299, domainMetadata#1300, commitInfo#1301]
Arguments: [txn#1292, add#1293, remove#1294, metaData#1295, protocol#1296, cdc#1297, checkpointMetadata#1298, sidecar#1299, domainMetadata#1300, commitInfo#1301], MapPartitionsRDD[114] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#1292, add#1293, remove#1294, metaData#1295, protocol#1296, cdc#1297, checkpointMetadata#1298, sidecar#1299, domainMetadata#1300, commitInfo#1301]
Condition : isnotnull(add#1293)
(3) Project [codegen id : 1]
Output [11]: [add#1293.path AS path#1345, add#1293.partitionValues AS partitionValues#1346, add#1293.size AS size#1347L, add#1293.modificationTime AS modificationTime#1348L, add#1293.dataChange AS dataChange#1349, add#1293.stats AS stats#1350, add#1293.tags AS tags#1351, add#1293.deletionVector AS deletionVector#1352, add#1293.baseRowId AS baseRowId#1353L, add#1293.defaultRowCommitVersion AS defaultRowCommitVersion#1354L, add#1293.clusteringProvider AS clusteringProvider#1355]
Input [10]: [txn#1292, add#1293, remove#1294, metaData#1295, protocol#1296, cdc#1297, checkpointMetadata#1298, sidecar#1299, domainMetadata#1300, commitInfo#1301]