== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#730973, add#730974, remove#730975, metaData#730976, protocol#730977, cdc#730978, checkpointMetadata#730979, sidecar#730980, domainMetadata#730981, commitInfo#730982]
Arguments: [txn#730973, add#730974, remove#730975, metaData#730976, protocol#730977, cdc#730978, checkpointMetadata#730979, sidecar#730980, domainMetadata#730981, commitInfo#730982], MapPartitionsRDD[34361] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#730973, add#730974, remove#730975, metaData#730976, protocol#730977, cdc#730978, checkpointMetadata#730979, sidecar#730980, domainMetadata#730981, commitInfo#730982]
Condition : isnotnull(add#730974)
(3) Project [codegen id : 1]
Output [11]: [add#730974.path AS path#731026, add#730974.partitionValues AS partitionValues#731027, add#730974.size AS size#731028L, add#730974.modificationTime AS modificationTime#731029L, add#730974.dataChange AS dataChange#731030, null AS stats#731037, add#730974.tags AS tags#731032, add#730974.deletionVector AS deletionVector#731033, add#730974.baseRowId AS baseRowId#731034L, add#730974.defaultRowCommitVersion AS defaultRowCommitVersion#731035L, add#730974.clusteringProvider AS clusteringProvider#731036]
Input [10]: [txn#730973, add#730974, remove#730975, metaData#730976, protocol#730977, cdc#730978, checkpointMetadata#730979, sidecar#730980, domainMetadata#730981, commitInfo#730982]