== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#20426, add#20427, remove#20428, metaData#20429, protocol#20430, cdc#20431, checkpointMetadata#20432, sidecar#20433, domainMetadata#20434, commitInfo#20435]
Arguments: [txn#20426, add#20427, remove#20428, metaData#20429, protocol#20430, cdc#20431, checkpointMetadata#20432, sidecar#20433, domainMetadata#20434, commitInfo#20435], MapPartitionsRDD[2022] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#20426, add#20427, remove#20428, metaData#20429, protocol#20430, cdc#20431, checkpointMetadata#20432, sidecar#20433, domainMetadata#20434, commitInfo#20435]
Condition : isnotnull(add#20427)
(3) Project [codegen id : 1]
Output [11]: [add#20427.path AS path#20479, add#20427.partitionValues AS partitionValues#20480, add#20427.size AS size#20481L, add#20427.modificationTime AS modificationTime#20482L, add#20427.dataChange AS dataChange#20483, add#20427.stats AS stats#20484, add#20427.tags AS tags#20485, add#20427.deletionVector AS deletionVector#20486, add#20427.baseRowId AS baseRowId#20487L, add#20427.defaultRowCommitVersion AS defaultRowCommitVersion#20488L, add#20427.clusteringProvider AS clusteringProvider#20489]
Input [10]: [txn#20426, add#20427, remove#20428, metaData#20429, protocol#20430, cdc#20431, checkpointMetadata#20432, sidecar#20433, domainMetadata#20434, commitInfo#20435]