== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#18300, add#18301, remove#18302, metaData#18303, protocol#18304, cdc#18305, checkpointMetadata#18306, sidecar#18307, domainMetadata#18308, commitInfo#18309]
Arguments: [txn#18300, add#18301, remove#18302, metaData#18303, protocol#18304, cdc#18305, checkpointMetadata#18306, sidecar#18307, domainMetadata#18308, commitInfo#18309], MapPartitionsRDD[1810] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#18300, add#18301, remove#18302, metaData#18303, protocol#18304, cdc#18305, checkpointMetadata#18306, sidecar#18307, domainMetadata#18308, commitInfo#18309]
Condition : isnotnull(add#18301)
(3) Project [codegen id : 1]
Output [11]: [add#18301.path AS path#18353, add#18301.partitionValues AS partitionValues#18354, add#18301.size AS size#18355L, add#18301.modificationTime AS modificationTime#18356L, add#18301.dataChange AS dataChange#18357, add#18301.stats AS stats#18358, add#18301.tags AS tags#18359, add#18301.deletionVector AS deletionVector#18360, add#18301.baseRowId AS baseRowId#18361L, add#18301.defaultRowCommitVersion AS defaultRowCommitVersion#18362L, add#18301.clusteringProvider AS clusteringProvider#18363]
Input [10]: [txn#18300, add#18301, remove#18302, metaData#18303, protocol#18304, cdc#18305, checkpointMetadata#18306, sidecar#18307, domainMetadata#18308, commitInfo#18309]