== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#21530060, add#21530061, remove#21530062, metaData#21530063, protocol#21530064, cdc#21530065, checkpointMetadata#21530066, sidecar#21530067, domainMetadata#21530068, commitInfo#21530069]
Arguments: [txn#21530060, add#21530061, remove#21530062, metaData#21530063, protocol#21530064, cdc#21530065, checkpointMetadata#21530066, sidecar#21530067, domainMetadata#21530068, commitInfo#21530069], MapPartitionsRDD[1241922] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#21530060, add#21530061, remove#21530062, metaData#21530063, protocol#21530064, cdc#21530065, checkpointMetadata#21530066, sidecar#21530067, domainMetadata#21530068, commitInfo#21530069]
Condition : isnotnull(add#21530061)
(3) Project [codegen id : 1]
Output [11]: [add#21530061.path AS path#21530113, add#21530061.partitionValues AS partitionValues#21530114, add#21530061.size AS size#21530115L, add#21530061.modificationTime AS modificationTime#21530116L, add#21530061.dataChange AS dataChange#21530117, null AS stats#21530124, add#21530061.tags AS tags#21530119, add#21530061.deletionVector AS deletionVector#21530120, add#21530061.baseRowId AS baseRowId#21530121L, add#21530061.defaultRowCommitVersion AS defaultRowCommitVersion#21530122L, add#21530061.clusteringProvider AS clusteringProvider#21530123]
Input [10]: [txn#21530060, add#21530061, remove#21530062, metaData#21530063, protocol#21530064, cdc#21530065, checkpointMetadata#21530066, sidecar#21530067, domainMetadata#21530068, commitInfo#21530069]