== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#20328, add#20329, remove#20330, metaData#20331, protocol#20332, cdc#20333, checkpointMetadata#20334, sidecar#20335, domainMetadata#20336, commitInfo#20337]
Arguments: [txn#20328, add#20329, remove#20330, metaData#20331, protocol#20332, cdc#20333, checkpointMetadata#20334, sidecar#20335, domainMetadata#20336, commitInfo#20337], MapPartitionsRDD[2018] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#20328, add#20329, remove#20330, metaData#20331, protocol#20332, cdc#20333, checkpointMetadata#20334, sidecar#20335, domainMetadata#20336, commitInfo#20337]
Condition : isnotnull(add#20329)
(3) Project [codegen id : 1]
Output [11]: [add#20329.path AS path#20381, add#20329.partitionValues AS partitionValues#20382, add#20329.size AS size#20383L, add#20329.modificationTime AS modificationTime#20384L, add#20329.dataChange AS dataChange#20385, null AS stats#20392, add#20329.tags AS tags#20387, add#20329.deletionVector AS deletionVector#20388, add#20329.baseRowId AS baseRowId#20389L, add#20329.defaultRowCommitVersion AS defaultRowCommitVersion#20390L, add#20329.clusteringProvider AS clusteringProvider#20391]
Input [10]: [txn#20328, add#20329, remove#20330, metaData#20331, protocol#20332, cdc#20333, checkpointMetadata#20334, sidecar#20335, domainMetadata#20336, commitInfo#20337]