== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#957566, add#957567, remove#957568, metaData#957569, protocol#957570, cdc#957571, checkpointMetadata#957572, sidecar#957573, domainMetadata#957574, commitInfo#957575]
Arguments: [txn#957566, add#957567, remove#957568, metaData#957569, protocol#957570, cdc#957571, checkpointMetadata#957572, sidecar#957573, domainMetadata#957574, commitInfo#957575], MapPartitionsRDD[47640] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#957566, add#957567, remove#957568, metaData#957569, protocol#957570, cdc#957571, checkpointMetadata#957572, sidecar#957573, domainMetadata#957574, commitInfo#957575]
Condition : isnotnull(add#957567)
(3) Project [codegen id : 1]
Output [11]: [add#957567.path AS path#957619, add#957567.partitionValues AS partitionValues#957620, add#957567.size AS size#957621L, add#957567.modificationTime AS modificationTime#957622L, add#957567.dataChange AS dataChange#957623, null AS stats#957630, add#957567.tags AS tags#957625, add#957567.deletionVector AS deletionVector#957626, add#957567.baseRowId AS baseRowId#957627L, add#957567.defaultRowCommitVersion AS defaultRowCommitVersion#957628L, add#957567.clusteringProvider AS clusteringProvider#957629]
Input [10]: [txn#957566, add#957567, remove#957568, metaData#957569, protocol#957570, cdc#957571, checkpointMetadata#957572, sidecar#957573, domainMetadata#957574, commitInfo#957575]