== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#1198946, add#1198947, remove#1198948, metaData#1198949, protocol#1198950, cdc#1198951, checkpointMetadata#1198952, sidecar#1198953, domainMetadata#1198954, commitInfo#1198955]
Arguments: [txn#1198946, add#1198947, remove#1198948, metaData#1198949, protocol#1198950, cdc#1198951, checkpointMetadata#1198952, sidecar#1198953, domainMetadata#1198954, commitInfo#1198955], MapPartitionsRDD[68918] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#1198946, add#1198947, remove#1198948, metaData#1198949, protocol#1198950, cdc#1198951, checkpointMetadata#1198952, sidecar#1198953, domainMetadata#1198954, commitInfo#1198955]
Condition : isnotnull(add#1198947)
(3) Project [codegen id : 1]
Output [11]: [add#1198947.path AS path#1198999, add#1198947.partitionValues AS partitionValues#1199000, add#1198947.size AS size#1199001L, add#1198947.modificationTime AS modificationTime#1199002L, add#1198947.dataChange AS dataChange#1199003, null AS stats#1199010, add#1198947.tags AS tags#1199005, add#1198947.deletionVector AS deletionVector#1199006, add#1198947.baseRowId AS baseRowId#1199007L, add#1198947.defaultRowCommitVersion AS defaultRowCommitVersion#1199008L, add#1198947.clusteringProvider AS clusteringProvider#1199009]
Input [10]: [txn#1198946, add#1198947, remove#1198948, metaData#1198949, protocol#1198950, cdc#1198951, checkpointMetadata#1198952, sidecar#1198953, domainMetadata#1198954, commitInfo#1198955]