== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#16174, add#16175, remove#16176, metaData#16177, protocol#16178, cdc#16179, checkpointMetadata#16180, sidecar#16181, domainMetadata#16182, commitInfo#16183]
Arguments: [txn#16174, add#16175, remove#16176, metaData#16177, protocol#16178, cdc#16179, checkpointMetadata#16180, sidecar#16181, domainMetadata#16182, commitInfo#16183], MapPartitionsRDD[1598] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#16174, add#16175, remove#16176, metaData#16177, protocol#16178, cdc#16179, checkpointMetadata#16180, sidecar#16181, domainMetadata#16182, commitInfo#16183]
Condition : isnotnull(add#16175)
(3) Project [codegen id : 1]
Output [11]: [add#16175.path AS path#16227, add#16175.partitionValues AS partitionValues#16228, add#16175.size AS size#16229L, add#16175.modificationTime AS modificationTime#16230L, add#16175.dataChange AS dataChange#16231, add#16175.stats AS stats#16232, add#16175.tags AS tags#16233, add#16175.deletionVector AS deletionVector#16234, add#16175.baseRowId AS baseRowId#16235L, add#16175.defaultRowCommitVersion AS defaultRowCommitVersion#16236L, add#16175.clusteringProvider AS clusteringProvider#16237]
Input [10]: [txn#16174, add#16175, remove#16176, metaData#16177, protocol#16178, cdc#16179, checkpointMetadata#16180, sidecar#16181, domainMetadata#16182, commitInfo#16183]