== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#25741, add#25742, remove#25743, metaData#25744, protocol#25745, cdc#25746, checkpointMetadata#25747, sidecar#25748, domainMetadata#25749, commitInfo#25750]
Arguments: [txn#25741, add#25742, remove#25743, metaData#25744, protocol#25745, cdc#25746, checkpointMetadata#25747, sidecar#25748, domainMetadata#25749, commitInfo#25750], MapPartitionsRDD[2552] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#25741, add#25742, remove#25743, metaData#25744, protocol#25745, cdc#25746, checkpointMetadata#25747, sidecar#25748, domainMetadata#25749, commitInfo#25750]
Condition : isnotnull(add#25742)
(3) Project [codegen id : 1]
Output [11]: [add#25742.path AS path#25794, add#25742.partitionValues AS partitionValues#25795, add#25742.size AS size#25796L, add#25742.modificationTime AS modificationTime#25797L, add#25742.dataChange AS dataChange#25798, add#25742.stats AS stats#25799, add#25742.tags AS tags#25800, add#25742.deletionVector AS deletionVector#25801, add#25742.baseRowId AS baseRowId#25802L, add#25742.defaultRowCommitVersion AS defaultRowCommitVersion#25803L, add#25742.clusteringProvider AS clusteringProvider#25804]
Input [10]: [txn#25741, add#25742, remove#25743, metaData#25744, protocol#25745, cdc#25746, checkpointMetadata#25747, sidecar#25748, domainMetadata#25749, commitInfo#25750]