== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#1342, add#1343, remove#1344, metaData#1345, protocol#1346, cdc#1347, checkpointMetadata#1348, sidecar#1349, domainMetadata#1350, commitInfo#1351]
Arguments: [txn#1342, add#1343, remove#1344, metaData#1345, protocol#1346, cdc#1347, checkpointMetadata#1348, sidecar#1349, domainMetadata#1350, commitInfo#1351], MapPartitionsRDD[124] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#1342, add#1343, remove#1344, metaData#1345, protocol#1346, cdc#1347, checkpointMetadata#1348, sidecar#1349, domainMetadata#1350, commitInfo#1351]
Condition : isnotnull(add#1343)
(3) Project [codegen id : 1]
Output [11]: [add#1343.path AS path#1395, add#1343.partitionValues AS partitionValues#1396, add#1343.size AS size#1397L, add#1343.modificationTime AS modificationTime#1398L, add#1343.dataChange AS dataChange#1399, add#1343.stats AS stats#1400, add#1343.tags AS tags#1401, add#1343.deletionVector AS deletionVector#1402, add#1343.baseRowId AS baseRowId#1403L, add#1343.defaultRowCommitVersion AS defaultRowCommitVersion#1404L, add#1343.clusteringProvider AS clusteringProvider#1405]
Input [10]: [txn#1342, add#1343, remove#1344, metaData#1345, protocol#1346, cdc#1347, checkpointMetadata#1348, sidecar#1349, domainMetadata#1350, commitInfo#1351]