== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#835367, add#835368, remove#835369, metaData#835370, protocol#835371, cdc#835372, checkpointMetadata#835373, sidecar#835374, domainMetadata#835375, commitInfo#835376]
Arguments: [txn#835367, add#835368, remove#835369, metaData#835370, protocol#835371, cdc#835372, checkpointMetadata#835373, sidecar#835374, domainMetadata#835375, commitInfo#835376], MapPartitionsRDD[39230] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#835367, add#835368, remove#835369, metaData#835370, protocol#835371, cdc#835372, checkpointMetadata#835373, sidecar#835374, domainMetadata#835375, commitInfo#835376]
Condition : isnotnull(add#835368)
(3) Project [codegen id : 1]
Output [11]: [add#835368.path AS path#835420, add#835368.partitionValues AS partitionValues#835421, add#835368.size AS size#835422L, add#835368.modificationTime AS modificationTime#835423L, add#835368.dataChange AS dataChange#835424, add#835368.stats AS stats#835425, add#835368.tags AS tags#835426, add#835368.deletionVector AS deletionVector#835427, add#835368.baseRowId AS baseRowId#835428L, add#835368.defaultRowCommitVersion AS defaultRowCommitVersion#835429L, add#835368.clusteringProvider AS clusteringProvider#835430]
Input [10]: [txn#835367, add#835368, remove#835369, metaData#835370, protocol#835371, cdc#835372, checkpointMetadata#835373, sidecar#835374, domainMetadata#835375, commitInfo#835376]