== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#1238970, add#1238971, remove#1238972, metaData#1238973, protocol#1238974, cdc#1238975, checkpointMetadata#1238976, sidecar#1238977, domainMetadata#1238978, commitInfo#1238979]
Arguments: [txn#1238970, add#1238971, remove#1238972, metaData#1238973, protocol#1238974, cdc#1238975, checkpointMetadata#1238976, sidecar#1238977, domainMetadata#1238978, commitInfo#1238979], MapPartitionsRDD[71052] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#1238970, add#1238971, remove#1238972, metaData#1238973, protocol#1238974, cdc#1238975, checkpointMetadata#1238976, sidecar#1238977, domainMetadata#1238978, commitInfo#1238979]
Condition : isnotnull(add#1238971)
(3) Project [codegen id : 1]
Output [11]: [add#1238971.path AS path#1239023, add#1238971.partitionValues AS partitionValues#1239024, add#1238971.size AS size#1239025L, add#1238971.modificationTime AS modificationTime#1239026L, add#1238971.dataChange AS dataChange#1239027, null AS stats#1239034, add#1238971.tags AS tags#1239029, add#1238971.deletionVector AS deletionVector#1239030, add#1238971.baseRowId AS baseRowId#1239031L, add#1238971.defaultRowCommitVersion AS defaultRowCommitVersion#1239032L, add#1238971.clusteringProvider AS clusteringProvider#1239033]
Input [10]: [txn#1238970, add#1238971, remove#1238972, metaData#1238973, protocol#1238974, cdc#1238975, checkpointMetadata#1238976, sidecar#1238977, domainMetadata#1238978, commitInfo#1238979]