== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#914653, add#914654, remove#914655, metaData#914656, protocol#914657, cdc#914658, checkpointMetadata#914659, sidecar#914660, domainMetadata#914661, commitInfo#914662]
Arguments: [txn#914653, add#914654, remove#914655, metaData#914656, protocol#914657, cdc#914658, checkpointMetadata#914659, sidecar#914660, domainMetadata#914661, commitInfo#914662], MapPartitionsRDD[45458] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#914653, add#914654, remove#914655, metaData#914656, protocol#914657, cdc#914658, checkpointMetadata#914659, sidecar#914660, domainMetadata#914661, commitInfo#914662]
Condition : isnotnull(add#914654)
(3) Project [codegen id : 1]
Output [11]: [add#914654.path AS path#914706, add#914654.partitionValues AS partitionValues#914707, add#914654.size AS size#914708L, add#914654.modificationTime AS modificationTime#914709L, add#914654.dataChange AS dataChange#914710, null AS stats#914717, add#914654.tags AS tags#914712, add#914654.deletionVector AS deletionVector#914713, add#914654.baseRowId AS baseRowId#914714L, add#914654.defaultRowCommitVersion AS defaultRowCommitVersion#914715L, add#914654.clusteringProvider AS clusteringProvider#914716]
Input [10]: [txn#914653, add#914654, remove#914655, metaData#914656, protocol#914657, cdc#914658, checkpointMetadata#914659, sidecar#914660, domainMetadata#914661, commitInfo#914662]