== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#818083, add#818084, remove#818085, metaData#818086, protocol#818087, cdc#818088, checkpointMetadata#818089, sidecar#818090, domainMetadata#818091, commitInfo#818092]
Arguments: [txn#818083, add#818084, remove#818085, metaData#818086, protocol#818087, cdc#818088, checkpointMetadata#818089, sidecar#818090, domainMetadata#818091, commitInfo#818092], MapPartitionsRDD[38409] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#818083, add#818084, remove#818085, metaData#818086, protocol#818087, cdc#818088, checkpointMetadata#818089, sidecar#818090, domainMetadata#818091, commitInfo#818092]
Condition : isnotnull(add#818084)
(3) Project [codegen id : 1]
Output [11]: [add#818084.path AS path#818136, add#818084.partitionValues AS partitionValues#818137, add#818084.size AS size#818138L, add#818084.modificationTime AS modificationTime#818139L, add#818084.dataChange AS dataChange#818140, add#818084.stats AS stats#818141, add#818084.tags AS tags#818142, add#818084.deletionVector AS deletionVector#818143, add#818084.baseRowId AS baseRowId#818144L, add#818084.defaultRowCommitVersion AS defaultRowCommitVersion#818145L, add#818084.clusteringProvider AS clusteringProvider#818146]
Input [10]: [txn#818083, add#818084, remove#818085, metaData#818086, protocol#818087, cdc#818088, checkpointMetadata#818089, sidecar#818090, domainMetadata#818091, commitInfo#818092]